jobflow_remote.jobs package

Submodules

• jobflow_remote.jobs.batch module
  • LocalBatchManager
    • LocalBatchManager.get_job()
    • LocalBatchManager.terminate_job()
  • RemoteBatchManager
    • RemoteBatchManager.delete_terminated()
    • RemoteBatchManager.get_running()
    • RemoteBatchManager.get_submitted()
    • RemoteBatchManager.get_terminated()
    • RemoteBatchManager.submit_job()
• jobflow_remote.jobs.daemon module
  • DaemonError
  • DaemonManager
    • DaemonManager.check_status()
    • DaemonManager.check_supervisord_process()
    • DaemonManager.clean_files()
    • DaemonManager.conf_filepath
    • DaemonManager.conf_template_single
    • DaemonManager.conf_template_split
    • DaemonManager.foreground_process()
    • DaemonManager.foreground_processes()
    • DaemonManager.from_project()
    • DaemonManager.from_project_name()
    • DaemonManager.get_controller()
    • DaemonManager.get_interface()
    • DaemonManager.get_processes_info()
    • DaemonManager.get_supervisord_pid()
    • DaemonManager.kill()
    • DaemonManager.log_filepath
    • DaemonManager.pid_filepath
    • DaemonManager.shut_down()
    • DaemonManager.sock_filepath
    • DaemonManager.start()
    • DaemonManager.start_processes()
    • DaemonManager.start_supervisord()
    • DaemonManager.stop()
    • DaemonManager.wait_start()
    • DaemonManager.write_config()
  • DaemonStatus
    • DaemonStatus.PARTIALLY_RUNNING
    • DaemonStatus.RUNNING
    • DaemonStatus.SHUT_DOWN
    • DaemonStatus.STARTING
    • DaemonStatus.STOPPED
    • DaemonStatus.STOPPING
• jobflow_remote.jobs.data module
  • DbCollection
    • DbCollection.AUX
    • DbCollection.FLOWS
    • DbCollection.JOBS
  • DynamicResponseType
    • DynamicResponseType.ADDITION
    • DynamicResponseType.DETOUR
    • DynamicResponseType.REPLACE
  • FlowDoc
    • FlowDoc.created_on
    • FlowDoc.ids
    • FlowDoc.jobs
    • FlowDoc.lock_id
    • FlowDoc.lock_time
    • FlowDoc.metadata
    • FlowDoc.name
    • FlowDoc.parents
    • FlowDoc.state
    • FlowDoc.updated_on
    • FlowDoc.uuid
    • FlowDoc.as_db_dict()
    • FlowDoc.descendants()
    • FlowDoc.children
    • FlowDoc.ids_mapping
    • FlowDoc.int_index_parents
  • FlowInfo
    • FlowInfo.created_on
    • FlowInfo.db_ids
    • FlowInfo.flow_id
    • FlowInfo.hosts
    • FlowInfo.job_ids
    • FlowInfo.job_indexes
    • FlowInfo.job_names
    • FlowInfo.job_states
    • FlowInfo.name
    • FlowInfo.parents
    • FlowInfo.state
    • FlowInfo.updated_on
    • FlowInfo.workers
    • FlowInfo.from_query_dict()
    • FlowInfo.iter_job_prop()
    • FlowInfo.ids_mapping
  • JobDoc
    • JobDoc.created_on
    • JobDoc.db_id
    • JobDoc.end_time
    • JobDoc.error
    • JobDoc.exec_config
    • JobDoc.index
    • JobDoc.job
    • JobDoc.lock_id
    • JobDoc.lock_time
    • JobDoc.parents
    • JobDoc.previous_state
    • JobDoc.priority
    • JobDoc.remote
    • JobDoc.resources
    • JobDoc.run_dir
    • JobDoc.start_time
    • JobDoc.state
    • JobDoc.stored_data
    • JobDoc.updated_on
    • JobDoc.uuid
    • JobDoc.worker
    • JobDoc.as_db_dict()
  • JobInfo
    • JobInfo.created_on
    • JobInfo.db_id
    • JobInfo.end_time
    • JobInfo.error
    • JobInfo.index
    • JobInfo.lock_id
    • JobInfo.lock_time
    • JobInfo.metadata
    • JobInfo.name
    • JobInfo.parents
    • JobInfo.previous_state
    • JobInfo.priority
    • JobInfo.remote
    • JobInfo.run_dir
    • JobInfo.start_time
    • JobInfo.state
    • JobInfo.updated_on
    • JobInfo.uuid
    • JobInfo.worker
    • JobInfo.from_query_output()
    • JobInfo.estimated_run_time
    • JobInfo.is_locked
    • JobInfo.run_time
  • RemoteError
  • RemoteInfo
    • RemoteInfo.error
    • RemoteInfo.process_id
    • RemoteInfo.queue_state
    • RemoteInfo.retry_time_limit
    • RemoteInfo.step_attempts
  • get_initial_flow_doc_dict()
  • get_initial_job_doc_dict()
  • get_reset_job_base_dict()
• jobflow_remote.jobs.graph module
  • get_graph()
  • get_graph_elements()
  • get_mermaid()
  • plot_dash()
• jobflow_remote.jobs.jobcontroller module
  • JobController
    • JobController.add_batch_process()
    • JobController.add_flow()
    • JobController.build_indexes()
    • JobController.checkin_job()
    • JobController.checkout_job()
    • JobController.close()
    • JobController.compact()
    • JobController.complete_job()
    • JobController.count_flows()
    • JobController.count_jobs()
    • JobController.create_indexes()
    • JobController.delete_flow()
    • JobController.delete_flows()
    • JobController.delete_job()
    • JobController.delete_jobs()
    • JobController.from_project()
    • JobController.from_project_name()
    • JobController.generate_job_id_query()
    • JobController.get_batch_processes()
    • JobController.get_collection()
    • JobController.get_flow_info_by_flow_uuid()
    • JobController.get_flow_info_by_job_uuid()
    • JobController.get_flow_job_aggreg()
    • JobController.get_flow_jobs_data()
    • JobController.get_flows_info()
    • JobController.get_job_doc()
    • JobController.get_job_info()
    • JobController.get_job_info_by_job_uuid()
    • JobController.get_job_info_by_pid()
    • JobController.get_job_uuids()
    • JobController.get_jobs()
    • JobController.get_jobs_doc()
    • JobController.get_jobs_doc_query()
    • JobController.get_jobs_info()
    • JobController.get_jobs_info_by_flow_uuid()
    • JobController.get_jobs_info_query()
    • JobController.lock_flow()
    • JobController.lock_job()
    • JobController.lock_job_flow()
    • JobController.lock_job_for_update()
    • JobController.pause_job()
    • JobController.pause_jobs()
    • JobController.ping_flow_doc()
    • JobController.play_job()
    • JobController.play_jobs()
    • JobController.refresh_children()
    • JobController.remove_batch_process()
    • JobController.rerun_job()
    • JobController.rerun_jobs()
    • JobController.reset()
    • JobController.retry_job()
    • JobController.retry_jobs()
    • JobController.set_job_doc_properties()
    • JobController.set_job_run_properties()
    • JobController.set_job_state()
    • JobController.stop_children()
    • JobController.stop_job()
    • JobController.stop_jobflow()
    • JobController.stop_jobs()
    • JobController.unlock_flows()
    • JobController.unlock_jobs()
    • JobController.update_flow_state()
  • get_flow_leafs()
• jobflow_remote.jobs.run module
  • decompress_files()
  • run_batch_jobs()
  • run_remote_job()
• jobflow_remote.jobs.runner module
  • Runner
    • Runner.advance_state()
    • Runner.check_run_status()
    • Runner.checkout()
    • Runner.cleanup()
    • Runner.complete_job()
    • Runner.download()
    • Runner.get_host()
    • Runner.get_queue_manager()
    • Runner.get_worker()
    • Runner.handle_signal()
    • Runner.refresh_num_current_jobs()
    • Runner.run()
    • Runner.run_all_jobs()
    • Runner.run_one_job()
    • Runner.runner_options
    • Runner.submit()
    • Runner.update_batch_jobs()
    • Runner.upload()
• jobflow_remote.jobs.state module
  • FlowState
    • FlowState.COMPLETED
    • FlowState.FAILED
    • FlowState.PAUSED
    • FlowState.READY
    • FlowState.RUNNING
    • FlowState.STOPPED
    • FlowState.WAITING
    • FlowState.from_jobs_states()
  • JobState
    • JobState.BATCH_RUNNING
    • JobState.BATCH_SUBMITTED
    • JobState.CHECKED_OUT
    • JobState.COMPLETED
    • JobState.DOWNLOADED
    • JobState.FAILED
    • JobState.PAUSED
    • JobState.READY
    • JobState.REMOTE_ERROR
    • JobState.RUNNING
    • JobState.STOPPED
    • JobState.SUBMITTED
    • JobState.TERMINATED
    • JobState.UPLOADED
    • JobState.USER_STOPPED
    • JobState.WAITING
    • JobState.short_value
• jobflow_remote.jobs.store module
  • get_jobstore()
• jobflow_remote.jobs.submit module
  • submit_flow()

Module contents