Source symbols: cognee_db_workers/kuzu_worker.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: 10
• Referenced calls: 28

Declared symbols

• _retry_open_locked — def at line 35; references range, sleep, min, Database, str, lower, get, remove, needs_migration, ladybug_migration, HandleResult, register, init_database, pop, hasattr, close, Connection, len, execute, has_next
• _open_database — def at line 71; references Database, get, str, lower, _retry_open_locked, remove, needs_migration, ladybug_migration, HandleResult, register, init_database, pop, hasattr, close, Connection, len, execute, has_next, get_next, append
• _db_init — def at line 112; references get, init_database, pop, hasattr, close, Connection, HandleResult, register, len, execute, has_next, get_next, append, tuple, as_py, install_json_extension_local, str
• _db_close — def at line 118; references pop, hasattr, close, get, Connection, HandleResult, register, len, execute, has_next, get_next, append, tuple, as_py, install_json_extension_local, str
• _open_connection — def at line 128; references get, Connection, HandleResult, register, pop, hasattr, close, len, execute, has_next, get_next, append, tuple, as_py, install_json_extension_local, str
• _conn_close — def at line 137; references pop, hasattr, close, get, len, execute, has_next, get_next, append, tuple, as_py, install_json_extension_local, str
• _conn_execute_fetch_all — def at line 147; references get, len, execute, has_next, get_next, append, tuple, as_py, hasattr, close, install_json_extension_local, str
• _install_json — def at line 178; references install_json_extension_local, get, execute, str
• _load_extension — def at line 185; references get, execute, str
• worker_main — def at line 215; references run_worker_loop

File-level call references

• import — line 13
• range — line 58
• sleep — line 61
• min — line 61
• Database — line 63
• str — line 65
• lower — line 65
• get — line 77
• _retry_open_locked — line 84
• remove — line 92
• needs_migration — line 98
• ladybug_migration — line 100
• HandleResult — line 109
• register — line 109
• init_database — line 114
• pop — line 119
• hasattr — line 120
• close — line 122
• Connection — line 133
• len — line 155
• execute — line 158
• has_next — line 164
• get_next — line 165
• append — line 166
• tuple — line 166
• as_py — line 166
• install_json_extension_local — line 181
• run_worker_loop — line 220

Source: cognee_db_workers/kuzu_worker.py