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