Corezoid Task Execution — Node Logic Dispatch

Corezoid Task Execution — Node Logic Dispatch A workflow diagram generated by Archify. 01 / Entry 02 / conveyor_worker 03 / Async executors EX / Error path Intake Logic dispatch Resume + finish worker_conditions3 logic list AMQP round trip API Client · create task · Entry › Intake API Client create task conveyor_api · publish to shard · Entry › Intake conveyor_api publish to shard Task Done · end_time set · Entry › Resume + finish Task Done end_time set Logic Dispatch · match logic head · conveyor_worker › worker_conditions3 logic list › Logic dispatch Logic Dispatch match logic head Sync Logic · set_param / go / sum · conveyor_worker › worker_conditions3 logic list › Logic dispatch Sync Logic set_param / go / sum Next Node · to_node_id · conveyor_worker › Resume + finish Next Node to_node_id Wait Tab · ETS correlation · Async executors › Logic dispatch Wait Tab ETS correlation Publish AMQP · per-logic exchange · Async executors › AMQP round trip › Logic dispatch Publish AMQP per-logic exchange Executor · http / gitcall · Async executors › AMQP round trip › Resume + finish Executor http / gitcall Merge Response · into task_data · Async executors › Resume + finish Merge Response into task_data Error Logic · err node route · Error path › Resume + finish Error Logic err node route Escalation · task to err branch · Error path › Resume + finish Escalation task to err branch consume by shard POST /api/2/json sync logic async logic register callback logic error correlated reply empty_logic continue walk Legend worker / engine error path AMQP publish ETS wait tab executor API caller

Logic families

  • • Sync: set_param, go, go_if_const, api_sum
  • • Async: api, api_code, api_rpc, db_call, git_call_v2

Async round trip

  • • worker publishes to the logic's exchange and returns
  • • Callback registered in worker_*_client_wait_tab ETS

Failure handling

  • • A failed logic routes to the node's error branch
  • • HTTP requests use a 3-tier retry chain