EventHandlers

class statefun_tasks.events.EventHandlers

__init__()

Methods

__init__()
notify_emit_result(context, ...)	Calls all notify_emit_result event handlers
notify_task_finished(context, task_result, ...)	Calls all notify_task_finished event handlers
notify_task_received(context, task_request)	Calls all on_task_received event handlers
notify_task_retry(context, task_request, ...)	Calls all notify_task_retry event handlers
notify_task_started(context, task_request)	Calls all on_task_started event handlers
on_emit_result(handler)	@tasks.events.on_emit_result decorator
on_task_finished(handler)	@tasks.events.on_task_finished decorator
on_task_received(handler)	@tasks.events.on_task_received decorator
on_task_retry(handler)	@tasks.events.on_task_retry decorator
on_task_started(handler)	@tasks.events.on_task_started decorator

async notify_emit_result(context, task_result_or_exception)

Calls all notify_emit_result event handlers

async notify_task_finished(context, task_result, task_exception, is_pipeline)

Calls all notify_task_finished event handlers

async notify_task_received(context, task_request)

Calls all on_task_received event handlers

async notify_task_retry(context, task_request, retry_count)

Calls all notify_task_retry event handlers

async notify_task_started(context, task_request)

Calls all on_task_started event handlers

on_emit_result(handler)

@tasks.events.on_emit_result decorator

on_task_finished(handler)

@tasks.events.on_task_finished decorator

on_task_received(handler)

@tasks.events.on_task_received decorator

on_task_retry(handler)

@tasks.events.on_task_retry decorator

on_task_started(handler)

@tasks.events.on_task_started decorator