Skip to main content

poll_workflow_task

Function poll_workflow_task 

Source
pub async fn poll_workflow_task<S: WorkflowStore>(
    __arg0: State<Arc<AppState<S>>>,
    __arg1: Json<PollWorkflowTaskRequest>,
) -> Result<Json<Value>, AppError>
Expand description

Claim a dispatchable workflow on the requested queue. Response is null when nothing is available (worker should sleep + retry).