The flow_runner processor is used to asynchronously consume requests in a queue by using the processing flow used for online requests.
Configuration Example #
A simple example is as follows:
pipeline: - name: bulk_request_ingest auto_start: true keep_running: true processor: - flow_runner: input_queue: "primary_deadletter_requests" flow: primary-flow-post-processing when: cluster_available: [ "primary" ]
Parameter Description #
|input_queue||string||Name of a subscribed queue|
|flow||string||Flow used to consume requests in consumption queues|
|commit_on_tag||string||A message is committed only when a specified tag exists in the context of the current request. The default value is blank, indicating that a message is committed immediately after the execution is complete.|