coulomb/activity-core
2
0
Fork 0
generated from coulomb/repo-seed
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Align activity-core scope boundaries

Browse Source
This commit is contained in:
Bernd Worsch
2026-06-18 15:11:48 +02:00
parent 78eed5f942
commit 977a3bd97f
7 changed files with 530 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/activity_core/workflows.py
View File

@@ -209,11 +209,12 @@ class RunActivityWorkflow:
@workflow.defn
class TaskExecutorWorkflow:
"""Child workflow that executes one concrete task instance.
"""Compatibility stub for legacy task-instance workflows.
Stub behaviour: persists a task_instances row with status=done and
returns immediately. Real task execution logic replaces this in a
later workstream.
This is not a production execution surface for activity-core. It persists a
task_instances row with status=done and returns immediately so legacy/dev
flows keep their idempotency behavior. Real task execution belongs in
per-repo workers or a future execution-owned repo/workplan, not here.
task_id is derived deterministically from the workflow's own ID so
persist_task_instance retries remain idempotent.
@@ -221,7 +222,7 @@ class TaskExecutorWorkflow:
@workflow.run
async def run(self, run_id: str, task_type: str, params: dict) -> dict:
# Derive a stable task_id from this workflow's own ID.
# Keep the stub idempotent without implying task lifecycle ownership.
task_id = str(
uuid.uuid5(uuid.NAMESPACE_URL, workflow.info().workflow_id)
)