freezer.tests.unit.scheduler package

Submodules

• freezer.tests.unit.scheduler.commons module
  • set_default_capabilities()
  • set_test_capabilities()
• freezer.tests.unit.scheduler.test_coordination module
  • TestCoordinationFunctionalFileDriver
    • TestCoordinationFunctionalFileDriver.setUp()
    • TestCoordinationFunctionalFileDriver.test_job_lock_is_exclusive_across_members()
    • TestCoordinationFunctionalFileDriver.test_rebalance_on_leave()
    • TestCoordinationFunctionalFileDriver.test_refresh_recovers_membership()
    • TestCoordinationFunctionalFileDriver.test_ring_agreement_exactly_one_owner()
    • TestCoordinationFunctionalFileDriver.test_single_member_owns_everything()
  • TestSchedulerCoordinator
    • TestSchedulerCoordinator.setUp()
    • TestSchedulerCoordinator.test_group_id_is_client_id()
    • TestSchedulerCoordinator.test_is_owner_false_when_other_owns()
    • TestSchedulerCoordinator.test_is_owner_false_without_ring()
    • TestSchedulerCoordinator.test_job_lock_acquired_and_released()
    • TestSchedulerCoordinator.test_job_lock_failsafe_on_backend_error()
    • TestSchedulerCoordinator.test_job_lock_not_acquired()
    • TestSchedulerCoordinator.test_job_lock_releases_and_propagates_on_body_error()
    • TestSchedulerCoordinator.test_member_id_is_unique_per_process()
    • TestSchedulerCoordinator.test_refresh_builds_ring_and_owns_some_jobs()
    • TestSchedulerCoordinator.test_refresh_failsafe_on_backend_error()
    • TestSchedulerCoordinator.test_refresh_rejoins_when_evicted()
    • TestSchedulerCoordinator.test_start_is_idempotent()
• freezer.tests.unit.scheduler.test_freezer_scheduler module
  • TestFreezerScheduler
    • TestFreezerScheduler.setUp()
    • TestFreezerScheduler.tearDown()
    • TestFreezerScheduler.test_filter_jobs()
    • TestFreezerScheduler.test_filter_jobs_centralized()
    • TestFreezerScheduler.test_job_lock_standalone_grants_run()
    • TestFreezerScheduler.test_owns_job_delegates_to_coordinator()
    • TestFreezerScheduler.test_owns_job_standalone_is_always_true()
    • TestFreezerScheduler.test_poll_abort_only_kills_locally_running_job()
    • TestFreezerScheduler.test_poll_keeps_running_job_despite_ownership_loss()
    • TestFreezerScheduler.test_poll_runs_jobs_owned()
    • TestFreezerScheduler.test_poll_skips_jobs_not_owned()
    • TestFreezerScheduler.test_poll_unschedules_job_when_ownership_lost()
    • TestFreezerScheduler.test_update_auth_options()
    • TestFreezerScheduler.test_update_job_metadata_filters_actions()
• freezer.tests.unit.scheduler.test_scheduler_daemon module
  • TestDaemon
    • TestDaemon.setUp()
    • TestDaemon.setUpClass()
    • TestDaemon.test_create()
    • TestDaemon.test_daemon_start_preserves_sockets()
    • TestDaemon.test_get_open_sockets()
    • TestDaemon.test_handle_program_exit_calls_scheduler_stop()
    • TestDaemon.test_handle_program_reload_calls_scheduler_reload()
    • TestDaemon.test_is_process_running_eperm()
    • TestDaemon.test_is_process_running_srch()
    • TestDaemon.test_is_process_running_success()
    • TestDaemon.test_pid_fname_in_tempdir()
    • TestDaemon.test_pid_not_exists()
    • TestDaemon.test_signal_map_handlers()
    • TestDaemon.test_start()
  • TestGetFilenos
    • TestGetFilenos.test_get_filenos_extended_attributes()
    • TestGetFilenos.test_get_filenos_no_stream()
    • TestGetFilenos.test_get_filenos_recursive()
    • TestGetFilenos.test_get_filenos_stream_no_fileno()
    • TestGetFilenos.test_get_filenos_with_valid_stream()
  • TestNoDaemon
    • TestNoDaemon.setUp()
    • TestNoDaemon.test_create()
    • TestNoDaemon.test_exit_handler()
    • TestNoDaemon.test_has_status_method()
    • TestNoDaemon.test_has_stop_method()
    • TestNoDaemon.test_reload_handler()
    • TestNoDaemon.test_start_exit_ok()
• freezer.tests.unit.scheduler.test_scheduler_job module
  • TestJobLockRetryBackoff
    • TestJobLockRetryBackoff.setUp()
    • TestJobLockRetryBackoff.test_add_job_failure_is_logged_not_raised()
    • TestJobLockRetryBackoff.test_attempts_freeze_once_capped()
    • TestJobLockRetryBackoff.test_cancel_swallows_missing_retry_job()
    • TestJobLockRetryBackoff.test_delay_is_capped_at_max()
    • TestJobLockRetryBackoff.test_first_retry_uses_base_delay()
    • TestJobLockRetryBackoff.test_retries_when_own_schedule_fires_later()
    • TestJobLockRetryBackoff.test_second_retry_doubles_the_delay()
    • TestJobLockRetryBackoff.test_skips_retry_when_own_schedule_fires_sooner()
    • TestJobLockRetryBackoff.test_success_resets_backoff_and_cancels_pending_retry()
  • TestSchedulerJob
    • TestSchedulerJob.setUp()
    • TestSchedulerJob.test()
    • TestSchedulerJob.test_save_action_to_disk()
    • TestSchedulerJob.test_save_action_with_bool_value_to_disk()
    • TestSchedulerJob.test_save_action_with_none_value_to_disk()
  • TestSchedulerJob1
    • TestSchedulerJob1.setUp()
    • TestSchedulerJob1.test_execute_job_action_env_propagation()
    • TestSchedulerJob1.test_get_schedule_args()
    • TestSchedulerJob1.test_job_can_be_removed()
    • TestSchedulerJob1.test_job_contains_exec()
    • TestSchedulerJob1.test_job_create()
    • TestSchedulerJob1.test_job_end_session()
    • TestSchedulerJob1.test_job_execute()
    • TestSchedulerJob1.test_job_execute_with_trust()
    • TestSchedulerJob1.test_job_finish()
    • TestSchedulerJob1.test_job_process_event()
    • TestSchedulerJob1.test_job_remove()
    • TestSchedulerJob1.test_job_result()
    • TestSchedulerJob1.test_job_schedule()
    • TestSchedulerJob1.test_job_schedule_cron_fields()
    • TestSchedulerJob1.test_job_schedule_end_date()
    • TestSchedulerJob1.test_job_session_id()
    • TestSchedulerJob1.test_job_session_tag()
    • TestSchedulerJob1.test_job_start_session()
    • TestSchedulerJob1.test_job_terminate_kill()
    • TestSchedulerJob1.test_job_unschedule()
    • TestSchedulerJob1.test_job_update_job_schedule_doc()
    • TestSchedulerJob1.test_job_upload_metadata()
    • TestSchedulerJob1.test_runningstate_abort()
    • TestSchedulerJob1.test_runningstate_remove()
    • TestSchedulerJob1.test_runningstate_start()
    • TestSchedulerJob1.test_runningstate_stop()
    • TestSchedulerJob1.test_save_action_to_file()
    • TestSchedulerJob1.test_scheduledstate_abort()
    • TestSchedulerJob1.test_scheduledstate_remove()
    • TestSchedulerJob1.test_scheduledstate_start()
    • TestSchedulerJob1.test_scheduledstate_stop()
    • TestSchedulerJob1.test_stopstate_abort()
    • TestSchedulerJob1.test_stopstate_remove()
    • TestSchedulerJob1.test_stopstate_start()
    • TestSchedulerJob1.test_stopstate_stop()
  • TestSchedulerJobCapabilities
    • TestSchedulerJobCapabilities.setUp()
    • TestSchedulerJobCapabilities.tearDown()
    • TestSchedulerJobCapabilities.test_job_supported_action()
    • TestSchedulerJobCapabilities.test_job_supported_engine()
    • TestSchedulerJobCapabilities.test_job_supported_mode()
    • TestSchedulerJobCapabilities.test_job_supported_storage()
    • TestSchedulerJobCapabilities.test_job_unsupported_action()
    • TestSchedulerJobCapabilities.test_job_unsupported_engine()
    • TestSchedulerJobCapabilities.test_job_unsupported_mode()
    • TestSchedulerJobCapabilities.test_job_unsupported_storage()
• freezer.tests.unit.scheduler.test_utils module
  • TestUtils
    • TestUtils.setUp()
    • TestUtils.test_del_register_error()
    • TestUtils.test_do_register()
    • TestUtils.test_do_register_is_central_false()
    • TestUtils.test_do_register_is_central_true()
    • TestUtils.test_find_config_files()
    • TestUtils.test_find_config_files_path()
    • TestUtils.test_get_active_jobs_from_api()
    • TestUtils.test_get_jobs_from_disk()
    • TestUtils.test_load_doc_from_json_file()
    • TestUtils.test_save_jobs_to_disk()
    • TestUtils.test_terminate_subprocess()
    • TestUtils.test_terminate_subprocess1()

Module contents