---

name: control-plane description: "Control-Plane subsystem in TTA.dev: get_task, get_run, put_run and related code. 88 symbols | 15 files | Cohesion: 81%"

Control_plane

88 symbols | 15 files | Cohesion: 81%

When to Use

• Working on control-plane-related functionality in TTA.dev
• Modifying get_task, get_run
• Navigating ttadev/control_plane/store.py, ttadev/control_plane/workflow_service.py

Key Files

| File | Symbols | |------|---------| | ttadev/control_plane/store.py | _read_map, _write_map, _lock_for, get_task, get_run (+10) | | ttadev/control_plane/workflow_service.py | _emit_control_plane_span, _now_iso, _make_workflow_gate_id, _get_workflow_step, _build_workflow_gate_decision_record (+6) | | ttadev/control_plane/task_service.py | _now, _now_iso, _current_agent_id, _find_gate, _ensure_gate_decider_allowed (+6) | | ttadev/control_plane/lease_service.py | _now, _now_iso, _validate_lock_owner, _acquire_lock, _expire_lease (+6) | | ttadev/control_plane/run_service.py | _now, _now_iso, get_run, get_lease_for_run, list_active_ownership (+5) | | ttadev/control_plane/models.py | to_dict, to_dict, from_dict, to_dict, from_dict (+4) | | ttadev/control_plane/service.py | list_runs, get_run, get_lease_for_run, heartbeat_run, acquire_file_lock (+2) | | tests/unit/test_l0_store.py | _now, test_task_roundtrip, test_run_roundtrip, test_lease_roundtrip_and_delete | | ttadev/cli/control.py | _handle_run_command, _handle_lock_command | | tests/unit/test_control_plane_trace_attribution.py | test_claim_task_stamps_trace_id_on_run, test_workflow_step_round_trips_trace_fields |

Entry Points

Start here when exploring this area:

• get_task (Function) — ttadev/control_plane/store.py:51
• get_run (Function) — ttadev/control_plane/store.py:66
• put_run (Function) — ttadev/control_plane/store.py:71
• list_leases (Function) — ttadev/control_plane/store.py:77
• get_lease_for_task (Function) — ttadev/control_plane/store.py:81

Key Symbols

| Symbol | Type | File | Line | |--------|------|------|------| | get_task | Function | ttadev/control_plane/store.py | 51 | | get_run | Function | ttadev/control_plane/store.py | 66 | | put_run | Function | ttadev/control_plane/store.py | 71 | | list_leases | Function | ttadev/control_plane/store.py | 77 | | get_lease_for_task | Function | ttadev/control_plane/store.py | 81 | | put_lease | Function | ttadev/control_plane/store.py | 92 | | delete_lease | Function | ttadev/control_plane/store.py | 98 | | put_lock | Function | ttadev/control_plane/store.py | 123 | | delete_lock | Function | ttadev/control_plane/store.py | 129 | | to_dict | Function | ttadev/control_plane/models.py | 481 | | to_dict | Function | ttadev/control_plane/models.py | 528 | | from_dict | Function | ttadev/control_plane/models.py | 539 | | to_dict | Function | ttadev/control_plane/models.py | 563 | | test_task_roundtrip | Function | tests/unit/test_l0_store.py | 12 | | test_run_roundtrip | Function | tests/unit/test_l0_store.py | 31 | | test_lease_roundtrip_and_delete | Function | tests/unit/test_l0_store.py | 50 | | get_run | Function | ttadev/control_plane/run_service.py | 160 | | get_lease_for_run | Function | ttadev/control_plane/run_service.py | 167 | | list_active_ownership | Function | ttadev/control_plane/run_service.py | 171 | | claim_task | Function | ttadev/control_plane/run_service.py | 213 |

Execution Flows

| Flow | Type | Steps | |------|------|-------| | Main → Get_integration | cross_community | 5 | | Main → Get_integration | cross_community | 5 | | Main → Get_integration | cross_community | 4 | | Acquire_workspace_lock → Release_locks_for_run | intra_community | 4 | | Acquire_file_lock → Release_locks_for_run | intra_community | 4 | | Finalize_tracked_workflow → _now | intra_community | 4 | | Decide_gate → _get_active_session | intra_community | 3 | | Decide_gate → _gate_role_matches | intra_community | 3 | | Control_claim_task → To_dict | cross_community | 3 | | Control_get_run → To_dict | cross_community | 3 |

Connected Areas

| Area | Connections | |------|-------------| | Unit | 17 calls | | Cli | 2 calls |

How to Explore

1. gitnexus_context({name: "get_task"}) — see callers and callees
2. gitnexus_query({query: "control_plane"}) — find related execution flows
3. Read key files listed above for implementation details