API documentation

General

• adaptive_scheduler.client_support module
  • add_log_file_handler()
  • args_to_env()
  • get_learner()
  • log_info()
  • log_now()
  • tell_done()
• adaptive_scheduler.server_support module
  • BaseManager
    • BaseManager.cancel()
    • BaseManager.is_started
    • BaseManager.start()
  • DatabaseManager
    • DatabaseManager.failed
    • DatabaseManager.as_df()
    • DatabaseManager.as_dicts()
    • DatabaseManager.create_empty_db()
    • DatabaseManager.is_done()
    • DatabaseManager.n_done()
    • DatabaseManager.update()
  • JobManager
    • JobManager.n_started
    • JobManager.max_job_starts
  • KillManager
  • MaxRestartsReachedError
  • RunManager
    • RunManager.job_names
    • RunManager.database_manager
    • RunManager.job_manager
    • RunManager.kill_manager
    • RunManager.start_time
    • RunManager.end_time
    • RunManager.cancel()
    • RunManager.cleanup()
    • RunManager.elapsed_time()
    • RunManager.get_database()
    • RunManager.info()
    • RunManager.job_starting_times()
    • RunManager.load_dataframes()
    • RunManager.load_learners()
    • RunManager.parse_log_files()
    • RunManager.remove_existing_data()
    • RunManager.start()
    • RunManager.status()
    • RunManager.task_status()
  • cleanup_scheduler_files()
  • get_allowed_url()
  • logs_with_string_or_condition()
  • parse_log_files()
  • periodically_clean_ipython_profiles()
  • slurm_run()
  • start_one_by_one()
• adaptive_scheduler.utils module
  • LRUCachedCallable
    • LRUCachedCallable.cache_dict
  • WrappedFunction
    • WrappedFunction._cache_key
  • add_constant_to_fname()
  • atomic_write()
  • cloudpickle_learners()
  • combine_sequence_learners()
  • combo2fname()
  • combo_to_fname()
  • connect_to_ipyparallel()
  • copy_from_sequence_learner()
  • expand_dict_columns()
  • fname_to_dataframe()
  • fname_to_learner()
  • fname_to_learner_fname()
  • hash_anything()
  • load_dataframes()
  • load_parallel()
  • log_exception()
  • maybe_round()
  • round_sigfigs()
  • save_dataframe()
  • save_parallel()
  • shared_memory_cache()
  • shuffle_list()
  • sleep_unless_task_is_done()
  • smart_goal()
  • split()
  • split_in_balancing_learners()
  • split_sequence_in_sequence_learners()
  • split_sequence_learner()
  • track_file_creation_progress()

Scheduler specific

• adaptive_scheduler.scheduler module
  • BaseScheduler
    • BaseScheduler.batch_fname()
    • BaseScheduler.cancel()
    • BaseScheduler.ext
    • BaseScheduler.extra_env_vars()
    • BaseScheduler.extra_scheduler()
    • BaseScheduler.extra_script()
    • BaseScheduler.job_names_to_job_ids()
    • BaseScheduler.job_script()
    • BaseScheduler.launcher
    • BaseScheduler.log_fname()
    • BaseScheduler.output_fnames()
    • BaseScheduler.queue()
    • BaseScheduler.queue_df()
    • BaseScheduler.sanatize_job_id()
    • BaseScheduler.single_job_script
    • BaseScheduler.start_job()
    • BaseScheduler.submit_cmd
    • BaseScheduler.write_job_script()
  • DefaultScheduler
  • LocalMockScheduler
    • LocalMockScheduler.extra_scheduler()
    • LocalMockScheduler.job_script()
    • LocalMockScheduler.queue()
    • LocalMockScheduler.start_job()
  • PBS
    • PBS.job_script()
    • PBS.output_fnames()
    • PBS.queue()
    • PBS.sanatize_job_id()
    • PBS.start_job()
  • SLURM
    • SLURM.cancel_jobs()
    • SLURM.job_script()
    • SLURM.partitions
    • SLURM.queue()
    • SLURM.start_job()
  • slurm_partitions()