akram48616/flowforge

FlowForge is a distributed workflow orchestration platform. A client submits a workflow through the gateway; the workflow service validates and stores its dependency graph. An execution request leads the execution service to fetch that definition, track task state, and dispatch ready tasks through Kafka. Workers execute task types and publish results; execution coordination handles retries, stale-dispatch recovery, and terminal status, which notifications consume. The README documents these cross-service flows; internal links not established by the supplied source excerpts are omitted.