You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have a function that ingests records to some stream.
The stream may succeed although accepted only a strict subset of the records list.
I would like to modify the records list before it is processed again by the backoff mechanism (when using the on_predicat decorator).
In particular, I would like to filter the records that were not accepted and have them processed again.
How would I do that?
The text was updated successfully, but these errors were encountered:
Off the top of my head, it sounds like you'd want to refactor such that the decorated function is being called with an immutable parameter that either succeeds or fails. However, I'm not sure I understand the problem as stated. Some example code might help.
Hello,
I have a function that ingests records to some stream.
The stream may succeed although accepted only a strict subset of the records list.
I would like to modify the records list before it is processed again by the backoff mechanism (when using the on_predicat decorator).
In particular, I would like to filter the records that were not accepted and have them processed again.
How would I do that?
The text was updated successfully, but these errors were encountered: