Source symbols: cognee_db_workers/harness.py
Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.
- Revision: main@90b4acaac937dc1c0aeffaead8b707c896ebf3db · 2026-07-22T09:03:55Z
- Declarations: 65
- Referenced calls: 121
Declared symbols
_env_float— def at line 34; referencesget,float,int,_env_int,field,count_env_int— def at line 48; referencesget,int,_env_float,field,countSubprocessTransportError— class at line 102; referencesfield,countRequest— class at line 112; referencesfield,countResponse— class at line 125; referencescountHandleResult— class at line 137; referencescountReplayStep— class at line 145; referencescountHandleRegistry— class at line 163; referencescount__init__— def at line 166; referencescountregister— def at line 170; referencesnext,popregister_at— def at line 175; referencespopget— def at line 186; referencespoppop— def at line 189_describe_exitcode— def at line 208; referencesstr,Signals,except,getset_pdeathsig— def at line 235; referencesfind_library,CDLL,prctlstart_parent_liveness_watchdog— def at line 268; referencesgetppid,_exit,sleep,Thread,start,Lock_watch— def at line 296; referencesgetppid,_exit,sleep,Thread,start,Lockspawn_without_main— class at line 326; referencesacquire,get,getattr,release,enable,_enable_faulthandler,set_pdeathsig,start_parent_liveness_watchdog,new_event_loop,set_event_loop,HandleRegistry,_env_int,ValueError,Semaphore,init,put,Response,format_exc,_safe_pickle_exception,set__enter__— def at line 334; referencesacquire,get,getattr,release,enable,_enable_faulthandler,set_pdeathsig,start_parent_liveness_watchdog,new_event_loop,set_event_loop,HandleRegistry,_env_int,ValueError,Semaphore,init,put,Response,format_exc,_safe_pickle_exception,set__exit__— def at line 355; referencesrelease,get,enable,_enable_faulthandler,set_pdeathsig,start_parent_liveness_watchdog,new_event_loop,set_event_loop,HandleRegistry,_env_int,ValueError,Semaphore,init,put,Response,format_exc,_safe_pickle_exception,set,isinstance,_emit_enable_faulthandler— def at line 375; referencesget,enable,set_pdeathsig,start_parent_liveness_watchdog,new_event_loop,set_event_loop,HandleRegistry,_env_int,ValueError,Semaphore,init,put,Response,format_exc,_safe_pickle_exception,set,isinstance,_emit,_emit_error,run_in_executorrun_worker_loop— def at line 402; references_enable_faulthandler,set_pdeathsig,start_parent_liveness_watchdog,new_event_loop,set_event_loop,HandleRegistry,_env_int,ValueError,Semaphore,init,put,Response,format_exc,_safe_pickle_exception,set,isinstance,_emit,_emit_error,run_in_executor,gather_emit— def at line 458; referencesisinstance,put,Response,format_exc,_safe_pickle_exception,_emit_error,run_in_executor,gather,getattr,get,handler,iscoroutine,create_task,_run_async,add,add_done_callback,run_until_complete,serve,close,dumps_emit_error— def at line 466; referencesput,Response,format_exc,_safe_pickle_exception,_emit,run_in_executor,gather,getattr,get,handler,iscoroutine,create_task,_run_async,add,add_done_callback,run_until_complete,serve,close,dumps,int_run_async— def at line 475; references_emit,_emit_error,run_in_executor,gather,put,Response,getattr,get,handler,iscoroutine,create_task,add,add_done_callback,run_until_complete,serve,close,dumps,int,collectserve— def at line 486; referencesrun_in_executor,gather,put,Response,getattr,get,handler,_emit_error,iscoroutine,create_task,_run_async,add,add_done_callback,_emit,run_until_complete,close,dumps,int,collect_safe_pickle_exception— def at line 528; referencesdumps,int,collect_op_gc_collect— def at line 536; referencesint,collectcollect_garbage_in_all_workers— def at line 558; referenceslist,is_set,is_alive,call,Request,_terminate,register,time,max,int_reap_all_sessions_atexit— def at line 587; referenceslist,_terminate,register,time,max,intSubprocessSession— class at line 612; referencestime,max,int__init__— def at line 619; referencestime,max,intpid— def at line 685last_accessed_at— def at line 689touch— def at line 692; referencestime_closed— def at line 699; referencesis_set_closed— def at line 703; referencesset,clear_init_diagnostics— def at line 709; referencesis_alive,monotonic,get_nowait,sleep,except,min,_terminate,set,SubprocessTransportError,_init_failure_message,get,_drain_response_after_death,add,_start_reader_thread,Thread,start,is_set,getattr,pop,done_init_failure_message— def at line 734; referencesmonotonic,get_nowait,sleep,except,min,_terminate,set,SubprocessTransportError,get,is_alive,_drain_response_after_death,add,_start_reader_thread,Thread,start,is_set,getattr,pop,done,set_result_drain_response_after_death— def at line 744; referencesmonotonic,get_nowait,sleep,except,min,_terminate,set,SubprocessTransportError,_init_failure_message,get,is_alive,add,_start_reader_thread,Thread,start,is_set,getattr,pop,done,set_resultwait_for_ready— def at line 773; referencesmonotonic,min,_terminate,set,SubprocessTransportError,_init_failure_message,get,is_alive,_drain_response_after_death,add,_start_reader_thread,Thread,start,is_set,except,getattr,pop,done,set_result,_fail_all_pending_start_reader_thread— def at line 844; referencesThread,start,is_set,get,is_alive,SubprocessTransportError,except,getattr,pop,done,set_result,set,_fail_all_pending_reader_loop— def at line 853; referencesis_set,get,is_alive,SubprocessTransportError,except,getattr,pop,done,set_result,set,_fail_all_pending_fail_all_pending— def at line 933add_replay_step— def at line 954; referencesappendremove_replay_step— def at line 964; referencesremove_register_pending— def at line 970; referencesis_set,SubprocessTransportError_issue— def at line 983; references_resolve_deadline,_check_alive,next,Future,_apply_remap,replace,_register_pending,touch,put,max,monotonic,result,TimeoutError,_reset_timeout_counter,_handle_response,pop_issue_async— def at line 1019; references_resolve_deadline,_check_alive,next,Future,_apply_remap,replace,_register_pending,touch,put,wrap_future,max,monotonic,wait_for,done,cancel,TimeoutError,_reset_timeout_counter,_handle_response,pop_record_timeout— def at line 1056; referencesset,_reset_timeout_counter,_issue,_can_respawn,_force_respawn_after_timeouts,_respawn,get_running_loop,_issue_async,run_in_executor,get,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,join_reset_timeout_counter— def at line 1064; referencesset,_issue,_can_respawn,_record_timeout,_force_respawn_after_timeouts,_respawn,get_running_loop,_issue_async,run_in_executor,get,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,join_force_respawn_after_timeouts— def at line 1068; referencesset,_reset_timeout_counter,_issue,_can_respawn,_record_timeout,_respawn,get_running_loop,_issue_async,run_in_executor,get,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,joincall— def at line 1081; references_issue,_can_respawn,_record_timeout,_force_respawn_after_timeouts,_respawn,get_running_loop,_issue_async,run_in_executor,get,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,joincall_async— def at line 1110; referencesget_running_loop,_issue_async,_can_respawn,_record_timeout,_force_respawn_after_timeouts,run_in_executor,get,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory_can_respawn— def at line 1136; referencesget,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory_apply_remap— def at line 1139; referencesget,replace,monotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory_resolve_deadline— def at line 1151; referencesmonotonic,float,hasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory,get_handle_response— def at line 1173; referenceshasattr,add_note,RuntimeError,is_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory,get_check_alive— def at line 1190; referencesis_set,SubprocessTransportError,is_alive,set,join,_terminate,_respawn_factory,get_respawn— def at line 1199; referencesSubprocessTransportError,is_set,is_alive,set,join,_terminate,_respawn_factory,get_raw_call_locked— def at line 1325; referencesnext,replace,touch,put,_resolve_deadline,get,TimeoutError,SubprocessTransportError,_handle_responseshutdown— def at line 1360; referencesis_set,set,is_alive,join,put,get,_terminate,_fail_all_pending,SubprocessTransportError,clear_terminate— def at line 1442; referencesjoin,is_alive,terminate,kill,monotonic,max__del__— def at line 1478; referencesshutdownget_process_rss_bytes— def at line 1485; referencesopen,int,read,split,sysconf,check_output,str,strip
File-level call references
get— line 38float— line 42int— line 57_env_float— line 65_env_int— line 66field— line 121count— line 167next— line 171pop— line 190str— line 224Signals— line 226except— line 227find_library— line 260CDLL— line 261prctl— line 262getppid— line 292_exit— line 305sleep— line 307Thread— line 311start— line 312Lock— line 323acquire— line 335getattr— line 339release— line 351enable— line 394_enable_faulthandler— line 421set_pdeathsig— line 428start_parent_liveness_watchdog— line 429new_event_loop— line 431set_event_loop— line 432HandleRegistry— line 433ValueError— line 441Semaphore— line 446init— line 450put— line 451Response— line 451format_exc— line 453_safe_pickle_exception— line 453set— line 456isinstance— line 459_emit— line 482_emit_error— line 484run_in_executor— line 490gather— line 496handler— line 507iscoroutine— line 512create_task— line 513_run_async— line 513add— line 514add_done_callback— line 515run_until_complete— line 520serve— line 520close— line 523dumps— line 530collect— line 543WeakSet— line 555list— line 572is_set— line 574is_alive— line 574call— line 580Request— line 580_terminate— line 604register— line 609time— line 634max— line 648Event— line 664clear— line 707monotonic— line 761get_nowait— line 764min— line 781SubprocessTransportError— line 788_init_failure_message— line 788_drain_response_after_death— line 807_start_reader_thread— line 842done— line 914set_result— line 921_fail_all_pending— line 929values— line 944set_exception— line 948append— line 962remove— line 966_resolve_deadline— line 989_check_alive— line 995Future— line 997_apply_remap— line 998replace— line 998_register_pending— line 999touch— line 1001result— line 1005TimeoutError— line 1007_reset_timeout_counter— line 1013_handle_response— line 1014wrap_future— line 1038wait_for— line 1041cancel— line 1046_issue— line 1096_can_respawn— line 1098_record_timeout— line 1100_force_respawn_after_timeouts— line 1101_respawn— line 1103get_running_loop— line 1118_issue_async— line 1122hasattr— line 1183add_note— line 1184RuntimeError— line 1187join— line 1229_respawn_factory— line 1247make_request— line 1288_raw_call_locked— line 1293apply_new_handle— line 1295items— line 1312setdefault— line 1315terminate— line 1463kill— line 1466shutdown— line 1480open— line 1491read— line 1492split— line 1492sysconf— line 1493check_output— line 1497
Source: cognee_db_workers/harness.py