Source symbols: celery/beat.py

Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.

• Revision: main@97ed017c09de03612a7d9617ff4c038c00bf916b · 2026-07-19T16:04:39Z
• Declarations: 77
• Referenced calls: 112

Declared symbols

• SchedulingError — class at line 46
• BeatLazyFunc — class at line 50
• __init__ — def at line 67
• __call__ — def at line 74; references delay, _func
• delay — def at line 77; references _func
• ScheduleEntry — class at line 82
• __init__ — def at line 117
• default_now — def at line 130; references now, __class__, dict, update
• _next_instance — def at line 134; references __class__, dict, default_now, update
• __reduce__ — def at line 143; references update
• update — def at line 149
• is_due — def at line 161; references iter, vars, items, format, reprcall
• __iter__ — def at line 165; references iter, vars, items, format, reprcall
• __repr__ — def at line 168; references format, reprcall
• __lt__ — def at line 175; references isinstance, getattr, editable_fields_equal
• editable_fields_equal — def at line 186; references getattr, isinstance
• __eq__ — def at line 192; references editable_fields_equal, isinstance
• _evaluate_entry_args — def at line 201; references isinstance
• _evaluate_entry_kwargs — def at line 210
• Scheduler — class at line 219; references maybe_evaluate
• __init__ — def at line 252; references maybe_evaluate
• install_default_entries — def at line 268
• apply_entry — def at line 279; references info, apply_async, error, format_stack, hasattr, debug, is_due, maybe_make_aware, default_now, mktime, utctimetuple, adjust, values, append, event_t, _when, heapify, schedules_equal, copy, populate_heap
• adjust — def at line 292; references is_due, maybe_make_aware, default_now, mktime, utctimetuple, values, append, event_t, _when, heapify, schedules_equal, copy, populate_heap, heappop, reserve, apply_entry, heappush, min, is_numeric_value, set
• is_due — def at line 297; references maybe_make_aware, default_now, mktime, utctimetuple, adjust, values, append, event_t, _when, heapify, schedules_equal, copy, populate_heap, heappop, reserve, apply_entry, heappush, min, is_numeric_value, set
• _when — def at line 300; references maybe_make_aware, default_now, mktime, utctimetuple, adjust, values, is_due, append, event_t, heapify, schedules_equal, copy, populate_heap, heappop, reserve, apply_entry, heappush, min, is_numeric_value, set
• populate_heap — def at line 310; references values, is_due, append, event_t, _when, heapify, schedules_equal, copy, heappop, reserve, apply_entry, heappush, min, adjust, is_numeric_value, set, keys, items, get, monotonic
• tick — def at line 326; references schedules_equal, copy, populate_heap, is_due, heappop, reserve, apply_entry, heappush, event_t, _when, min, adjust, is_numeric_value, set, keys, items, get, monotonic, next, _evaluate_entry_args
• schedules_equal — def at line 366; references set, keys, items, get, monotonic, next, reserve, _evaluate_entry_args, _evaluate_entry_kwargs, apply_async, send_task, reraise, SchedulingError, format, exc_info, should_sync, _do_sync, install_default_entries, merge_inplace, debug
• should_sync — def at line 381; references monotonic, next, reserve, get, _evaluate_entry_args, _evaluate_entry_kwargs, apply_async, send_task, reraise, SchedulingError, format, exc_info, _do_sync, install_default_entries, merge_inplace, debug, sync, Entry, isinstance, dict
• reserve — def at line 389; references next, get, _evaluate_entry_args, _evaluate_entry_kwargs, apply_async, send_task, reraise, SchedulingError, format, exc_info, should_sync, _do_sync, install_default_entries, merge_inplace, debug, sync, monotonic, Entry, isinstance, dict
• apply_async — def at line 393; references reserve, get, _evaluate_entry_args, _evaluate_entry_kwargs, send_task, reraise, SchedulingError, format, exc_info, should_sync, _do_sync, install_default_entries, merge_inplace, debug, sync, monotonic, Entry, isinstance, dict, update
• send_task — def at line 420; references install_default_entries, merge_inplace, debug, sync, monotonic, Entry, isinstance, dict, update, _maybe_entry, items
• setup_schedule — def at line 423; references install_default_entries, merge_inplace, debug, sync, monotonic, Entry, isinstance, dict, update, _maybe_entry, items
• _do_sync — def at line 427; references debug, sync, monotonic, Entry, isinstance, dict, update, _maybe_entry, items
• sync — def at line 435; references Entry, isinstance, dict, update, _maybe_entry, items
• close — def at line 438; references sync, Entry, isinstance, dict, update, _maybe_entry, items
• add — def at line 441; references Entry, isinstance, dict, update, _maybe_entry, items
• _maybe_entry — def at line 446; references isinstance, Entry, dict, update, items
• update_from_dict — def at line 452; references update, _maybe_entry, items
• merge_inplace — def at line 458; references set, pop, Entry, dict, get, update, error, ensure_connection, property, connection_for_write, Producer, _ensure_connected, super, __init__, ignore_errno, remove, open, _remove_db, _open_schedule, keys
• _ensure_connected — def at line 474; references error, ensure_connection, property, connection_for_write, Producer, get, super, __init__, ignore_errno, remove, open, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• _error_handler — def at line 477; references error, ensure_connection, property, connection_for_write, Producer, _ensure_connected, get, super, __init__, ignore_errno, remove, open, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• get_schedule — def at line 485; references property, connection_for_write, Producer, _ensure_connected, get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• set_schedule — def at line 488; references property, connection_for_write, Producer, _ensure_connected, get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• connection — def at line 493; references connection_for_write, Producer, _ensure_connected, get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• producer — def at line 497; references Producer, _ensure_connected, get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• info — def at line 501; references get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• PersistentScheduler — class at line 505; references get, super, __init__, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• __init__ — def at line 513; references get, super, ignore_errno, remove, open, error, _remove_db, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, warning, clear
• _remove_db — def at line 517; references ignore_errno, remove, open, error, _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, get, warning, clear
• _open_schedule — def at line 522; references open, error, _remove_db, keys, _destroy_open_corrupted_schedule, _create_schedule, get, warning, clear
• _destroy_open_corrupted_schedule — def at line 525; references error, _remove_db, _open_schedule, keys, _create_schedule, get, warning, clear
• setup_schedule — def at line 531; references _open_schedule, keys, _destroy_open_corrupted_schedule, _create_schedule, get, warning, clear
• _create_schedule — def at line 569; references except
• get_schedule — def at line 592
• set_schedule — def at line 595; references property
• sync — def at line 599
• close — def at line 603; references sync
• info — def at line 608
• Service — class at line 612; references Event, info, debug, humanize_seconds, send, set_process_title, is_set, tick, sleep, should_sync, _do_sync, except, set, sync, close, wait, dict, load_extension_class_names, symbol_by_name, get_scheduler
• __init__ — def at line 617; references Event
• __reduce__ — def at line 629
• start — def at line 633; references info, debug, humanize_seconds, send, set_process_title, is_set, tick, sleep, should_sync, _do_sync, except, set, sync
• sync — def at line 657; references close, set
• stop — def at line 661; references info, set, wait
• get_scheduler — def at line 666; references dict, load_extension_class_names, symbol_by_name
• scheduler — def at line 678; references get_scheduler
• _Threaded — class at line 682; references super, __init__, Service, set_current, start, stop, ensure_multiprocessing, reset_signals, close_open_fds, list, iter_open_logger_fds, set_default, terminate
• __init__ — def at line 685; references super, Service
• run — def at line 692; references set_current, start
• stop — def at line 696; references ensure_multiprocessing
• _Process — class at line 705; references super, __init__, Service, reset_signals, close_open_fds, list, iter_open_logger_fds, set_default, set_current, start, stop, terminate
• __init__ — def at line 707; references super, Service
• run — def at line 713; references reset_signals, close_open_fds, list, iter_open_logger_fds, set_default, set_current, start
• stop — def at line 722; references terminate
• EmbeddedService — def at line 727; references pop, _Threaded, _Process

File-level call references

• namedtuple — line 37
• get_logger — line 39
• delay — line 75
• _func — line 78
• maybe_schedule — line 126
• default_now — line 127
• now — line 131
• __class__ — line 136
• dict — line 136
• update — line 155
• is_due — line 163
• iter — line 166
• vars — line 166
• items — line 166
• format — line 169
• reprcall — line 171
• type — line 172
• isinstance — line 176
• getattr — line 188
• editable_fields_equal — line 198
• maybe_evaluate — line 255
• setup_schedule — line 266
• crontab — line 275
• update_from_dict — line 277
• info — line 280
• apply_async — line 282
• error — line 284
• format_stack — line 285
• hasattr — line 287
• debug — line 288
• maybe_make_aware — line 304
• mktime — line 306
• utctimetuple — line 306
• adjust — line 308
• values — line 314
• append — line 316
• event_t — line 316
• _when — line 317
• heapify — line 323
• schedules_equal — line 339
• copy — line 340
• populate_heap — line 341
• heappop — line 352
• reserve — line 354
• apply_entry — line 355
• heappush — line 356
• min — line 361
• is_numeric_value — line 363
• set — line 371
• keys — line 371
• get — line 374
• monotonic — line 384
• next — line 390
• _evaluate_entry_args — line 401
• _evaluate_entry_kwargs — line 402
• send_task — line 408
• reraise — line 412
• SchedulingError — line 412
• exc_info — line 414
• should_sync — line 417
• _do_sync — line 418
• install_default_entries — line 424
• merge_inplace — line 425
• sync — line 430
• Entry — line 442
• _maybe_entry — line 454
• pop — line 464
• ensure_connection — line 481
• property — line 490
• connection_for_write — line 494
• Producer — line 498
• _ensure_connected — line 498
• super — line 515
• __init__ — line 515
• ignore_errno — line 519
• remove — line 520
• open — line 523
• _remove_db — line 528
• _open_schedule — line 529
• _destroy_open_corrupted_schedule — line 541
• _create_schedule — line 543
• warning — line 548
• clear — line 549
• setdefault — line 557
• join — line 566
• repr — line 567
• except — line 573
• close — line 605
• Event — line 626
• humanize_seconds — line 636
• send — line 638
• set_process_title — line 641
• is_set — line 644
• tick — line 645
• sleep — line 649
• wait — line 664
• load_extension_class_names — line 669
• symbol_by_name — line 670
• get_scheduler — line 679
• Service — line 688
• set_current — line 693
• start — line 694
• stop — line 697
• ensure_multiprocessing — line 701
• reset_signals — line 714
• close_open_fds — line 715
• list — line 717
• iter_open_logger_fds — line 717
• set_default — line 718
• terminate — line 724
• _Threaded — line 737
• _Process — line 738

Source: celery/beat.py