Run Task

class arroyo.processing.strategies.run_task.RunTask(function: Callable[[Message[TStrategyPayload]], TResult], next_step: ProcessingStrategy[FilteredPayload | TResult])

Basic strategy to run a custom processing function on a message.

The processing function provided can raise InvalidMessage to indicate that the message is invalid and should be put in a dead letter queue.