Hi guys! Suppose the are job running [:in :my-func :my-func :out] with one flow condition from :in to :my-func, so the task :my-func throw some exception. My question is: when the task retry it will pass in flow-condition again or not?

@lellis It depends on how far the input stream needs to rewind - it's probably safe to assume that flow conditions would evaluate again

@michaeldrogalis There is any chance the task retry without pass in flow-condition again?

@lellis Possibly. I can't recall the details in that area of code. @lucasbradstreet?

If your fn throws an exception that is not handled, the task will rewind to the point at which it was committed and depending on what your code does it will end up performing the same operations. So if your code always throws on that data it will throw again.

That will cause it to keep throwing over and over. So you need to handle any non transitory exceptions in your code.

Ok, but the flow-condition will trigger again?

or only the task

If your using the kafka plugin it’ll play back the stream again so yes

im using datomic-plugin

:onyx.plugin.datomic/read-log-calls

K. Same deal. It’ll restart from an earlier tx, and everything will be performed as before, tasks, flow conditions, etc

nice! ty @lucasbradstreet and @michaeldrogalis!!