refactor(cron): pack scheduler re-export blocks
This commit is contained in:
+30
-100
@@ -3262,111 +3262,41 @@ if __name__ == "__main__":
|
||||
# monkeypatch target).
|
||||
# ---------------------------------------------------------------------------
|
||||
from cron.scheduler_delivery import ( # noqa: E402,F401
|
||||
BOT_CHAT_PLATFORM,
|
||||
_HOME_TARGET_ENV_VARS,
|
||||
_IMAGE_EXTS,
|
||||
_KNOWN_DELIVERY_PLATFORMS,
|
||||
_LEGACY_HOME_TARGET_ENV_VARS,
|
||||
_MIRROR_PROVENANCE_RANK,
|
||||
_ROUTING_TOKENS,
|
||||
_TargetDelivery,
|
||||
_VIDEO_EXTS,
|
||||
_confirm_adapter_delivery,
|
||||
_cron_delivery_notify_enabled,
|
||||
_cron_job_origin_log_suffix,
|
||||
_cron_mirror_delivery_enabled,
|
||||
_deliver_result,
|
||||
_deliver_standalone,
|
||||
_deliver_to_bot_chat,
|
||||
_deliver_via_live_adapter,
|
||||
_delivery_lane_value,
|
||||
_env_home_target_chat_id,
|
||||
_expand_routing_tokens,
|
||||
_get_bot_chat_delivery_timeout,
|
||||
_get_config_home_channel,
|
||||
_get_home_target_chat_id,
|
||||
_get_home_target_thread_id,
|
||||
_home_target,
|
||||
_inchannel_seed_allowed,
|
||||
_inchannel_surface_supported,
|
||||
_is_channel_dm_topic,
|
||||
_is_known_delivery_platform,
|
||||
_iter_home_target_platforms,
|
||||
_live_route_metadata,
|
||||
_live_send_media,
|
||||
_live_send_text,
|
||||
_maybe_mirror_cron_delivery,
|
||||
_normalize_deliver_value,
|
||||
_note_target_error,
|
||||
_open_continuable_cron_thread,
|
||||
_origin_delivery_thread,
|
||||
_origin_thread_is_stale,
|
||||
_plugin_cron_env_var,
|
||||
_record_delivery_verification,
|
||||
_relay_fronted_delivery_platforms,
|
||||
_resolve_bot_chat_target,
|
||||
_resolve_cron_surface_mode,
|
||||
_resolve_delivery_target,
|
||||
_resolve_delivery_targets,
|
||||
_resolve_home_env_var,
|
||||
_resolve_origin,
|
||||
_resolve_single_delivery_target,
|
||||
_resolve_target_transport,
|
||||
_seed_cron_channel_session,
|
||||
_seed_cron_session,
|
||||
_seed_cron_thread_session,
|
||||
_seed_live_delivery_sessions,
|
||||
_send_media_via_adapter,
|
||||
_standalone_send,
|
||||
_target_matches_origin,
|
||||
_target_mirror_eligible,
|
||||
_warn_live_lane_failure,
|
||||
cron_delivery_targets,
|
||||
parse_bot_chat_deliver_token,
|
||||
BOT_CHAT_PLATFORM, _HOME_TARGET_ENV_VARS, _IMAGE_EXTS, _KNOWN_DELIVERY_PLATFORMS,
|
||||
_LEGACY_HOME_TARGET_ENV_VARS, _MIRROR_PROVENANCE_RANK, _ROUTING_TOKENS, _TargetDelivery,
|
||||
_VIDEO_EXTS, _confirm_adapter_delivery, _cron_delivery_notify_enabled,
|
||||
_cron_job_origin_log_suffix, _cron_mirror_delivery_enabled, _deliver_result,
|
||||
_deliver_standalone, _deliver_to_bot_chat, _deliver_via_live_adapter, _delivery_lane_value,
|
||||
_env_home_target_chat_id, _expand_routing_tokens, _get_bot_chat_delivery_timeout,
|
||||
_get_config_home_channel, _get_home_target_chat_id, _get_home_target_thread_id, _home_target,
|
||||
_inchannel_seed_allowed, _inchannel_surface_supported, _is_channel_dm_topic,
|
||||
_is_known_delivery_platform, _iter_home_target_platforms, _live_route_metadata,
|
||||
_live_send_media, _live_send_text, _maybe_mirror_cron_delivery, _normalize_deliver_value,
|
||||
_note_target_error, _open_continuable_cron_thread, _origin_delivery_thread,
|
||||
_origin_thread_is_stale, _plugin_cron_env_var, _record_delivery_verification,
|
||||
_relay_fronted_delivery_platforms, _resolve_bot_chat_target, _resolve_cron_surface_mode,
|
||||
_resolve_delivery_target, _resolve_delivery_targets, _resolve_home_env_var, _resolve_origin,
|
||||
_resolve_single_delivery_target, _resolve_target_transport, _seed_cron_channel_session,
|
||||
_seed_cron_session, _seed_cron_thread_session, _seed_live_delivery_sessions,
|
||||
_send_media_via_adapter, _standalone_send, _target_matches_origin, _target_mirror_eligible,
|
||||
_warn_live_lane_failure, cron_delivery_targets, parse_bot_chat_deliver_token,
|
||||
)
|
||||
from cron.scheduler_script import ( # noqa: E402,F401
|
||||
_DEFAULT_MEDIA_SEND_TIMEOUT,
|
||||
_drain_script_pipes,
|
||||
_get_media_send_timeout,
|
||||
_get_script_timeout,
|
||||
_get_session_db_timeout,
|
||||
_read_windows_pyvenv_cfg,
|
||||
_run_job_script,
|
||||
_run_job_script_with_claim_heartbeat,
|
||||
_start_heartbeat_thread,
|
||||
_terminate_cron_script_process,
|
||||
_terminate_cron_script_tree,
|
||||
_windows_cron_bootstrap_argv,
|
||||
_windows_cron_python_invocation,
|
||||
_DEFAULT_MEDIA_SEND_TIMEOUT, _drain_script_pipes, _get_media_send_timeout, _get_script_timeout,
|
||||
_get_session_db_timeout, _read_windows_pyvenv_cfg, _run_job_script,
|
||||
_run_job_script_with_claim_heartbeat, _start_heartbeat_thread, _terminate_cron_script_process,
|
||||
_terminate_cron_script_tree, _windows_cron_bootstrap_argv, _windows_cron_python_invocation,
|
||||
)
|
||||
from cron.scheduler_prompt import ( # noqa: E402,F401
|
||||
_MAX_CONTEXT_CHARS,
|
||||
_block_and_pause_job,
|
||||
_build_job_prompt,
|
||||
_guard_job_credential_exfil,
|
||||
_inject_context_from,
|
||||
_load_cron_skill_parts,
|
||||
_parse_wake_gate,
|
||||
_prepend_context_block,
|
||||
_MAX_CONTEXT_CHARS, _block_and_pause_job, _build_job_prompt, _guard_job_credential_exfil,
|
||||
_inject_context_from, _load_cron_skill_parts, _parse_wake_gate, _prepend_context_block,
|
||||
_scan_assembled_cron_prompt,
|
||||
)
|
||||
from cron.scheduler_preflight import ( # noqa: E402,F401
|
||||
BLOCKED_CONFIG_MARKER,
|
||||
BLOCKED_CONFIG_SILENT_MARKER,
|
||||
DRIFT_SKIP_MARKER,
|
||||
DRIFT_SKIP_SILENT_MARKER,
|
||||
SharedRouteAdapters,
|
||||
_DNS_FAILURE_NEEDLES,
|
||||
_TRANSIENT_ERRNOS,
|
||||
_TRANSIENT_HTTP_NEEDLES,
|
||||
_TRANSIENT_NET_EXC_NAMES,
|
||||
_TRANSIENT_OSERROR_NEEDLES,
|
||||
_cron_preflight_enabled,
|
||||
_delivery_platform_routed_from_primary_gateway,
|
||||
_is_transient_provider_resolve_error,
|
||||
_preflight_check_delivery,
|
||||
_preflight_check_provider_key,
|
||||
_preflight_check_skills,
|
||||
_preflight_job_config,
|
||||
_primary_profile_routes_for_current_home,
|
||||
BLOCKED_CONFIG_MARKER, BLOCKED_CONFIG_SILENT_MARKER, DRIFT_SKIP_MARKER,
|
||||
DRIFT_SKIP_SILENT_MARKER, SharedRouteAdapters, _DNS_FAILURE_NEEDLES, _TRANSIENT_ERRNOS,
|
||||
_TRANSIENT_HTTP_NEEDLES, _TRANSIENT_NET_EXC_NAMES, _TRANSIENT_OSERROR_NEEDLES,
|
||||
_cron_preflight_enabled, _delivery_platform_routed_from_primary_gateway,
|
||||
_is_transient_provider_resolve_error, _preflight_check_delivery, _preflight_check_provider_key,
|
||||
_preflight_check_skills, _preflight_job_config, _primary_profile_routes_for_current_home,
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user