Index

_

__call__() (client.cli._HelpAction method) (client.swarm.workflow_run.SwarmCommand method) (core.config.structlog_config._NamedPrintLoggerFactory method) (distributor.distributor_command.DistributorCommand method) __enter__() (client.workflow.DistributorContext method) __eq__() (client.node.Node method) (client.swarm.swarm_array.SwarmArray method) (client.swarm.swarm_task.SwarmTask method) (client.task.Task method) (client.task_resources.TaskResources method) (distributor.distributor_task_instance.DistributorTaskInstance method) (distributor.distributor_workflow_run.DistributorWorkflowRun method) (distributor.task_instance_batch.TaskInstanceBatch method) __exit__() (client.workflow.DistributorContext method) __getattr__() (core.config.structlog_config._NamedPrintLogger method) __hash__() (client.dag.Dag method) (client.node.Node method) (client.swarm.swarm_array.SwarmArray method) (client.swarm.swarm_task.SwarmTask method) (client.task.Task method) (client.task_resources.TaskResources method) (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.workflow.Workflow method) (distributor.distributor_task_instance.DistributorTaskInstance method) (distributor.distributor_workflow_run.DistributorWorkflowRun method) (distributor.task_instance_batch.TaskInstanceBatch method) __jobmon_named_factory__ (core.config.structlog_config._NamedPrintLoggerFactory attribute) __lt__() (client.node.Node method) (client.swarm.swarm_array.SwarmArray method) (client.swarm.swarm_task.SwarmTask method) (client.task.Task method) (distributor.distributor_task_instance.DistributorTaskInstance method) (distributor.distributor_workflow_run.DistributorWorkflowRun method) (distributor.task_instance_batch.TaskInstanceBatch method) __repr__() (client.dag.Dag method) (client.node.Node method) (client.task.Task method) (client.task_resources.TaskResources method) (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method) (client.workflow.Workflow method) (client.workflow_run.WorkflowRun method) (core.config.structlog_config._NamedPrintLogger method) (distributor.distributor_task_instance.DistributorTaskInstance method) (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun method) __setitem__() (dummy.dummy_distributor.LimitedSizeDict method) (sequential.seq_distributor.LimitedSizeDict method) __slots__ (core.config.structlog_config._NamedPrintLogger attribute) __str__() (server.web.server_side_exception.ServerSideException method) __table_args__ (server.web.models.array.Array attribute) (server.web.models.node.Node attribute) (server.web.models.queue.Queue attribute) (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.task_template.TaskTemplate attribute) (server.web.models.task_template_version.TaskTemplateVersion attribute) (server.web.models.workflow_run.WorkflowRun attribute) __tablename__ (server.web.models.arg.Arg attribute) (server.web.models.arg_type.ArgType attribute) (server.web.models.array.Array attribute) (server.web.models.cluster.Cluster attribute) (server.web.models.cluster_type.ClusterType attribute) (server.web.models.dag.Dag attribute) (server.web.models.edge.Edge attribute) (server.web.models.node.Node attribute) (server.web.models.node_arg.NodeArg attribute) (server.web.models.queue.Queue attribute) (server.web.models.task.Task attribute) (server.web.models.task_arg.TaskArg attribute) (server.web.models.task_attribute.TaskAttribute attribute) (server.web.models.task_attribute_type.TaskAttributeType attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_resources.TaskResources attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.task_template.TaskTemplate attribute) (server.web.models.task_template_version.TaskTemplateVersion attribute) (server.web.models.template_arg_map.TemplateArgMap attribute) (server.web.models.tool.Tool attribute) (server.web.models.tool_version.ToolVersion attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_attribute.WorkflowAttribute attribute) (server.web.models.workflow_attribute_type.WorkflowAttributeType attribute) (server.web.models.workflow_run.WorkflowRun attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) __version__ (in module client) (in module core) (in module distributor) (in module dummy) (in module multiprocess) (in module sequential) (in module server) (in module worker_node) _aborted_state() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _active_task_template_version (client.task_template.TaskTemplate attribute) _add_concurrency_limit_subparser() (client.cli.ClientCLI method) _add_create_resource_yaml_subparser() (client.cli.ClientCLI method) _add_distributor_parser() (distributor.cli.DistributorCLI method) _add_get_filepaths_subparser() (client.cli.ClientCLI method) _add_init_db_subparser() (server.cli.ServerCLI method) _add_multi_value_filter() (server.web.repositories.workflow_repository.WorkflowRepository method) _add_or_get_attribute_types() (in module server.web.routes.v3.fsm.task) _add_or_get_wf_attribute_type() (in module server.web.routes.v3.fsm.workflow) _add_resume_workflow_parser() (client.cli.ClientCLI method) _add_run_task_generator_parser() (worker_node.cli.WorkerNodeCLI method) _add_task_dependencies_subparser() (client.cli.ClientCLI method) _add_task_status_subparser() (client.cli.ClientCLI method) _add_task_template_resources_subparser() (client.cli.ClientCLI method) _add_terminate_db_subparser() (server.cli.ServerCLI method) _add_update_config_subparser() (client.cli.ClientCLI method) _add_update_task_status_subparser() (client.cli.ClientCLI method) _add_upgrade_db_subparser() (server.cli.ServerCLI method) _add_version_subparser() (client.cli.ClientCLI method) _add_worker_node_array_parser() (worker_node.cli.WorkerNodeCLI method) _add_worker_node_job_parser() (worker_node.cli.WorkerNodeCLI method) _add_workflow_attributes() (in module server.web.routes.v3.fsm.workflow) _add_workflow_reaper_subparser() (server.cli.ServerCLI method) _add_workflow_reset_subparser() (client.cli.ClientCLI method) _add_workflow_status_subparser() (client.cli.ClientCLI method) _add_workflow_tasks_subparser() (client.cli.ClientCLI method) _all_tasks_final() (client.swarm.workflow_run.WorkflowRun method) _apply_heartbeat_response() (client.swarm.workflow_run.WorkflowRun method) _apply_task_status_updates() (client.swarm.workflow_run.WorkflowRun method) _args (client.swarm.workflow_run.SwarmCommand attribute) (distributor.distributor_command.DistributorCommand attribute) _array_step_id (multiprocess.multiproc_distributor.MultiprocessWorkerNode attribute) _base_factory (core.config.structlog_config._NamedPrintLoggerFactory attribute) _bind() (client.tool.Tool method) _bind_task_args() (client.workflow.Workflow method) _bind_task_attributes() (client.workflow.Workflow method) _bind_tasks() (client.workflow.Workflow method) _build_exporter_args() (in module core.otlp.manager) _build_structlog_processor_chain() (in module core.config.structlog_config) _bulk_bind_nodes() (client.dag.Dag method) _bulk_insert_edges() (client.dag.Dag method) _cache (core.cluster_type.ClusterType attribute) _capture_registered (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) _check_downstream_tasks_status() (in module server.web.routes.v3.cli.workflow) _check_fail_after_n_executions() (client.swarm.workflow_run.WorkflowRun method) _check_instantiated_for_work() (distributor.distributor_service.DistributorService method) _check_kill_self_for_work() (distributor.distributor_service.DistributorService method) _check_no_heartbeat_for_work() (distributor.distributor_service.DistributorService method) _check_queued_for_work() (distributor.distributor_service.DistributorService method) _check_size_limit() (dummy.dummy_distributor.LimitedSizeDict method) (sequential.seq_distributor.LimitedSizeDict method) _check_triaging_for_work() (distributor.distributor_service.DistributorService method) _chunk_ids() (in module client.status_commands) _chunk_size (client.workflow.Workflow attribute) _clean_arg_name() (in module core.task_generator) _cli_label_mapping (in module server.web.repositories.workflow_repository) _cli_order (in module server.web.repositories.workflow_repository) _close_session() (client.swarm.workflow_run.WorkflowRun method) _cluster_name (client.workflow.DistributorContext attribute) (dummy.dummy_distributor.DummyDistributor attribute) (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) (sequential.seq_distributor.SequentialDistributor attribute) (worker_node.worker_node_factory.WorkerNodeFactory attribute) _cluster_resource_check() (core.task_generator.TaskGenerator method) _clusters (client.workflow.Workflow attribute) _coerce_value() (core.configuration.JobmonConfig method) _command (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _command_add_env (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _command_generator_map (distributor.distributor_service.DistributorService attribute) _communicate() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance static method) _compare_versions() (in module server.web.utils.json_compat) _CONFIG (in module server.web.auth) (in module server.web.routes.auth.oidc.oidc) (in module server.web.routes.utils) _configure_client_logging_for_direct_rendering() (in module client.logging) _configure_component_logging() (client.workflow.Workflow method) _configure_log_processor() (core.otlp.manager.JobmonOTLPManager method) _configure_span_exporters() (core.otlp.manager.JobmonOTLPManager method) _convert_to_task_resource_detail_item() (server.web.repositories.task_template_repository.TaskTemplateRepository method) _core_manager (server.web.otlp.manager.ServerOTLPManager attribute) (server.web.otlp.ServerOTLPManager attribute) _create_component_processor() (in module core.config.structlog_config) _create_log_exporter() (core.otlp.manager.JobmonOTLPManager method) _create_span_exporter() (core.otlp.manager.JobmonOTLPManager method) _create_yaml() (in module client.status_commands) _current_starting_row (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _dag (client.workflow.Workflow attribute) _decide_run_loop_continue() (client.swarm.workflow_run.WorkflowRun method) _default_cluster_name (core.task_generator.TaskGenerator attribute) _default_compute_resources (core.task_generator.TaskGenerator attribute) _DEFAULT_LOG_FORMAT (in module client.logging) (in module server.web.logging) _default_max_attempts (client.workflow.Workflow attribute) _default_resource_scales (core.task_generator.TaskGenerator attribute) _dict_config (core.configuration.JobmonConfig attribute) _distributor_commands (distributor.distributor_service.DistributorService attribute) _distributor_id (dummy.dummy_distributor.DummyWorkerNode attribute) (multiprocess.multiproc_distributor.MultiprocessWorkerNode attribute) (sequential.seq_distributor.SequentialWorkerNode attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _engine (in module server.web.db.engine) _ensure_initialized() (core.otlp.handlers.JobmonOTLPLoggingHandler method) (core.otlp.JobmonOTLPLoggingHandler method) _ensure_jobmon_otlp_handlers() (in module client.logging) _ensure_logger_name() (in module core.config.structlog_config) _ensure_session() (client.swarm.workflow_run.WorkflowRun method) _error_state() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _errors (client.task.Task attribute) _exit_info (dummy.dummy_distributor.DummyDistributor attribute) (sequential.seq_distributor.SequentialDistributor attribute) _exporter_config (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) _extract_attributes() (core.otlp.handlers.JobmonOTLPLoggingHandler method) (core.otlp.JobmonOTLPLoggingHandler method) _extract_exc_info() (in module core.config.structlog_config) _extract_value() (in module core.structlog_utils) _fail_after_n_executions (client.workflow.Workflow attribute) _fastapi_instrumented (server.web.otlp.manager.ServerOTLPManager attribute) (server.web.otlp.ServerOTLPManager attribute) _find_executable_path() (in module core.task_generator) _find_ttvid() (server.web.repositories.task_template_repository.TaskTemplateRepository method) _flush_otlp_once() (in module core.otlp.manager) _force_flush_logger_provider() (core.otlp.manager.JobmonOTLPManager method) _force_flush_tracer_provider() (core.otlp.manager.JobmonOTLPManager method) _format_description() (in module core.task_generator) _format_options() (in module core.task_generator) _forward_event_to_logging_handlers() (in module core.config.structlog_config) _func (client.swarm.workflow_run.SwarmCommand attribute) (distributor.distributor_command.DistributorCommand attribute) _generate_module_section() (core.task_generator.TaskGeneratorModuleDocumenter method) _generate_nodes() (in module core.task_generator) _generate_task_template() (core.task_generator.TaskGenerator method) _get_active_tasks_count() (client.swarm.workflow_run.WorkflowRun method) _get_all_task_ids() (server.web.repositories.task_repository.TaskRepository method) _get_attributes() (core.otlp.resources.BaseJobmonResourceDetector method) (core.otlp.resources.HostResourceDetector method) (core.otlp.resources.JobmonServiceResourceDetector method) (core.otlp.resources.ProcessResourceDetector method) _get_collection_type() (in module core.task_generator) _get_component_template_path() (in module core.config.logconfig_utils) _get_config_file_from_installer_plug_in() (in module core) _get_content_async() (core.requester.Requester method) _get_current_structlog_context() (core.requester.Requester method) _get_current_time() (client.swarm.workflow_run.WorkflowRun method) _get_dag_and_wf_id() (server.web.repositories.task_repository.TaskRepository method) _get_dag_id() (client.dag.Dag method) _get_dict_config_variable() (core.configuration.JobmonConfig method) _get_env_var_name() (core.configuration.JobmonConfig method) _get_environment_variable() (core.configuration.JobmonConfig method) _get_generic_type_parameters() (in module core.task_generator)

_get_lost_workflow_runs() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _get_node_dependencies() (server.web.repositories.task_repository.TaskRepository method) _get_param_names_and_descriptions() (core.task_generator.TaskGenerator method) _get_ready_to_run_count() (client.swarm.workflow_run.WorkflowRun method) _get_recursive_task_ids() (server.web.repositories.task_repository.TaskRepository method) _get_severity_map() (core.otlp.handlers.JobmonOTLPLoggingHandler class method) (core.otlp.JobmonOTLPLoggingHandler class method) _get_short_description() (in module core.task_generator) _get_subdag() (server.web.repositories.task_repository.TaskRepository method) _get_subtask_id() (multiprocess.multiproc_distributor.MultiprocessDistributor method) _get_task_resource_details_with_node_args() (server.web.repositories.task_template_repository.TaskTemplateRepository method) _get_tasks_from_nodes() (server.web.repositories.task_repository.TaskRepository method) _get_tasks_recursive() (server.web.repositories.task_repository.TaskRepository method) _get_time() (in module server.web.routes) _get_time_till_next_heartbeat() (client.swarm.workflow_run.WorkflowRun method) _get_validation_error_message() (in module server.web.routes.v3.cli.task) _get_wf_name_args() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _get_workflow_run() (server.web.repositories.task_repository.TaskRepository method) _get_yaml_data() (in module client.status_commands) _get_yaml_variable() (core.configuration.JobmonConfig method) _halted_state() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _handle_done_status() (server.web.repositories.task_repository.TaskRepository method) _handle_error() (in module server.web.hooks_and_handlers) _handle_registering_status() (server.web.repositories.task_repository.TaskRepository method) _has_active_or_ready_tasks() (client.swarm.workflow_run.WorkflowRun method) _has_isolation_processor() (in module core.config.structlog_config) _hash_node_args() (client.node.Node method) _hash_task_args() (client.task.Task method) _heartbeat_loop() (client.swarm.workflow_run.WorkflowRun method) _heartbeat_task (client.swarm.workflow_run.WorkflowRun attribute) _HelpAction (class in client.cli) _id_name_map (client.task_template_version.TaskTemplateVersion attribute) _inconsistent_status() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) _init_lock (core.otlp.manager.JobmonOTLPManager attribute) _init_otlp() (core.requester.Requester class method) _initialize_signal_handlers() (distributor.distributor_service.DistributorService method) _initialized (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) (core.otlp.manager.JobmonOTLPManager attribute) (server.web.otlp.manager.ServerOTLPManager attribute) (server.web.otlp.ServerOTLPManager attribute) _insert_node_args() (in module server.web.routes.v3.fsm.node) _install_lifecycle_hooks() (in module core.otlp.manager) _instance (core.otlp.manager.JobmonOTLPManager attribute) _instance_cluster_name (client.array.Array attribute) (client.task.Task attribute) _instance_compute_resource (client.array.Array attribute) _instance_compute_resources (client.task.Task attribute) _instance_compute_resources_callable (client.task.Task attribute) _instance_lock (core.otlp.manager.JobmonOTLPManager attribute) _instance_max_attempts (client.array.Array attribute) (client.task.Task attribute) _instance_resource_scales (client.array.Array attribute) (client.task.Task attribute) _interface (core.cluster_type.ClusterType attribute) _interpolate_env_vars() (core.configuration.JobmonConfig method) _is_annotated_built_in_collection_type() (in module core.task_generator) _is_cyclic() (client.dag.Dag method) _is_multidimensional_type() (in module core.task_generator) _is_timely_transition() (server.web.models.task_instance.TaskInstance method) (server.web.models.workflow.Workflow method) (server.web.models.workflow_run.WorkflowRun method) _is_unannotated_built_in_collection_type() (in module core.task_generator) _is_valid_annotation() (core.task_generator.TaskGenerator method) _is_valid_type() (core.task_generator.TaskGenerator method) _iter_factory_candidates() (in module core.config.structlog_config) _kill_active_task_instances() (server.web.repositories.task_repository.TaskRepository method) _kwargs (client.swarm.workflow_run.SwarmCommand attribute) (distributor.distributor_command.DistributorCommand attribute) _last_heartbeat_time (client.swarm.workflow_run.WorkflowRun attribute) (distributor.distributor_service.DistributorService attribute) _link_array_and_workflow() (client.workflow.Workflow method) _load_module_task_generators() (core.task_generator.TaskGeneratorModuleDocumenter method) _load_task_generator() (core.task_generator.TaskGeneratorDocumenter method) _load_tool_versions() (client.tool.Tool method) _log_error() (in module server.web.routes.v3.fsm.task_instance) _log_heartbeat() (client.swarm.workflow_run.WorkflowRun method) _log_heartbeat_async() (client.swarm.workflow_run.WorkflowRun method) _log_heartbeat_by_batch() (distributor.distributor_service.DistributorService method) _log_heartbeats() (distributor.distributor_service.DistributorService method) _log_processor_configured (core.otlp.manager.JobmonOTLPManager attribute) _logfile_template (dummy.dummy_distributor.DummyWorkerNode attribute) (multiprocess.multiproc_distributor.MultiprocessWorkerNode attribute) (sequential.seq_distributor.SequentialWorkerNode attribute) _logger (core.config.structlog_config._NamedPrintLogger attribute) (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) _logger_provider (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) (in module core.otlp.manager) _logger_provider_lock (in module core.otlp.manager) _looks_like_direct_rendering_factory() (in module core.config.structlog_config) _matching_wf_args_diff_hash() (client.workflow.Workflow method) _maybe_retry() (core.requester.Requester method) _maybe_retry_async() (core.requester.Requester method) _maybe_trace() (core.requester.Requester method) _merge_dicts() (core.configuration.JobmonConfig method) _n_executions (client.swarm.workflow_run.WorkflowRun attribute) _NamedPrintLogger (class in core.config.structlog_config) _NamedPrintLoggerFactory (class in core.config.structlog_config) _naming_args (core.task_generator.TaskGenerator attribute) _next_distributor_id (dummy.dummy_distributor.DummyDistributor attribute) (sequential.seq_distributor.SequentialDistributor attribute) _next_job_id (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) _next_report_increment (distributor.distributor_service.DistributorService property) _node_args (client.task_template_version.TaskTemplateVersion attribute) _node_id (client.node.Node attribute) _normalize_context_key() (in module core.logging.context) _normalize_context_keys() (in module core.logging.context) _normalize_context_metadata() (in module core.logging.context) _normalize_exporter_config() (in module core.otlp.manager) _oauth_setup (in module server.web.auth) _op_args (client.task_template_version.TaskTemplateVersion attribute) _otlp_capture_lock (in module core.config.structlog_config) _otlp_handler_count (in module core.config.structlog_config) _otlp_manager (core.requester.Requester attribute) _package_location (core.cluster_type.ClusterType attribute) _parallelism (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) _parameters (dummy.dummy_queue.DummyQueue attribute) (multiprocess.multiproc_queue.MultiprocessQueue attribute) (sequential.seq_queue.SequentialQueue attribute) _parse_trace_context() (core.otlp.handlers.JobmonOTLPLoggingHandler method) (core.otlp.JobmonOTLPLoggingHandler method) _plugins (core.cluster_type.ClusterType attribute) _poll_interval_seconds (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _process_poller() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) _processor_present() (in module core.config.structlog_config) _prune_event_dict_for_console() (in module core.config.structlog_config) _queue_id (dummy.dummy_queue.DummyQueue attribute) (multiprocess.multiproc_queue.MultiprocessQueue attribute) (sequential.seq_queue.SequentialQueue attribute) _queue_name (dummy.dummy_queue.DummyQueue attribute) (multiprocess.multiproc_queue.MultiprocessQueue attribute) (sequential.seq_queue.SequentialQueue attribute) _reaper_message (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _record_exception_in_span() (in module server.web.hooks_and_handlers) _refresh_task_status_map() (client.swarm.workflow_run.WorkflowRun method) _register_atexit_hook() (in module core.otlp.manager) _register_signal_handlers() (in module core.otlp.manager) _remove_non_jobmon_handlers() (in module client.logging) _request_async() (client.swarm.workflow_run.WorkflowRun method) _requester (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun attribute) (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _requests_instrumented (server.web.otlp.manager.ServerOTLPManager attribute) (server.web.otlp.ServerOTLPManager attribute) _reset_singletons() (in module server.web.db.engine) _reversed_cli_label_mapping (in module server.web.repositories.workflow_repository) _reversed_task_instance_label_mapping (in module server.web.repositories.task_repository) _root (core.config.template_loader.TemplateLoader attribute) _run_async() (client.swarm.workflow_run.WorkflowRun method) _run_cmd() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) _run_coroutine() (client.swarm.workflow_run.WorkflowRun method) _running_or_submitted (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) _send_request() (core.requester.Requester method) _send_request_async() (core.requester.Requester method) _server_logging_configured (in module server.web.logging) _server_otlp_manager (in module server.web.otlp.manager) _session (client.swarm.workflow_run.WorkflowRun attribute) _session_scope() (in module server.web.db.deps) _SessionMaker (in module server.web.db.engine) _set_adjusted_task_resources() (client.swarm.workflow_run.WorkflowRun method) _set_fail_after_n_executions() (client.swarm.workflow_run.WorkflowRun method) _set_original_task_resources() (client.workflow.Workflow method) _set_status_for_triaging_async() (client.swarm.workflow_run.WorkflowRun method) _set_validated_task_resources() (client.swarm.workflow_run.WorkflowRun method) _SEVERITY_MAP (core.otlp.handlers.JobmonOTLPLoggingHandler attribute) (core.otlp.JobmonOTLPLoggingHandler attribute) _should_retry_exception() (core.requester.Requester method) _shutdown() (client.workflow.DistributorContext method) _shutdown_invoked (in module core.otlp.manager) _shutdown_lock (in module core.otlp.manager) _shutdown_otlp_providers() (core.cli.CLI method) _signal_handlers_installed (in module core.otlp.manager) _split_unit() (client.units.MemUnit static method) _sqlalchemy_instrumented (server.web.otlp.manager.ServerOTLPManager attribute) (server.web.otlp.ServerOTLPManager attribute) _status (client.swarm.workflow_run.WorkflowRun attribute) (client.workflow_run.WorkflowRun attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _stderr (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _stdout (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _stop_event (client.swarm.workflow_run.WorkflowRun attribute) _store_event_dict_for_otlp() (in module core.config.structlog_config) _structlog_configured_by_jobmon (in module client.logging) _structlog_configured_lock (in module client.logging) _subparsers (client.cli.ClientCLI attribute) (core.configuration.ConfigCLI attribute) (distributor.cli.DistributorCLI attribute) (server.cli.ServerCLI attribute) (worker_node.cli.WorkerNodeCLI attribute) _subtask_id (multiprocess.multiproc_distributor.MultiprocessWorkerNode attribute) _synchronize_array_max_concurrently_running_async() (client.swarm.workflow_run.WorkflowRun method) _synchronize_max_concurrently_running_async() (client.swarm.workflow_run.WorkflowRun method) _task_args (client.task_template_version.TaskTemplateVersion attribute) _task_instance_batches (distributor.distributor_service.DistributorService attribute) _task_instance_id (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) _task_instance_label_mapping (in module server.web.repositories.task_repository) _task_instance_status_map (distributor.distributor_service.DistributorService attribute) _task_instances (distributor.distributor_service.DistributorService attribute) _task_resources (client.swarm.workflow_run.WorkflowRun attribute) (client.workflow.Workflow attribute) _task_status_map (client.swarm.workflow_run.WorkflowRun attribute) _task_status_updates_async() (client.swarm.workflow_run.WorkflowRun method) _task_template (client.task_template_version.TaskTemplateVersion attribute) (core.task_generator.TaskGenerator attribute) _task_template_id (client.task_template.TaskTemplate attribute) _task_template_version_id (client.task_template_version.TaskTemplateVersion attribute) _task_template_versions (client.task_template.TaskTemplate attribute) _teardown_async() (client.swarm.workflow_run.WorkflowRun method) _TELEMETRY_PREFIX (in module core.logging.context) _templates (core.config.template_loader.TemplateLoader attribute) _terminate_task_instances_async() (client.swarm.workflow_run.WorkflowRun method) _terminated (client.swarm.workflow_run.WorkflowRun attribute) _thread_local (in module core.config.structlog_config) _timeout (client.workflow.DistributorContext attribute) _to_B() (client.units.MemUnit static method) _token (server.workflow_reaper.notifiers.SlackNotifier attribute) _tool (client.tool_version.ToolVersion attribute) _tool_version (client.task_template.TaskTemplate attribute) (client.workflow.Workflow attribute) _transition_to_error() (distributor.distributor_task_instance.DistributorTaskInstance method) _update_internal_states() (multiprocess.multiproc_distributor.MultiprocessDistributor method) _update_status() (client.swarm.workflow_run.WorkflowRun method) (client.workflow_run.WorkflowRun method) (distributor.distributor_workflow_run.DistributorWorkflowRun method) _update_status_async() (client.swarm.workflow_run.WorkflowRun method) _update_task_instance_state() (in module server.web.routes.v3.fsm.task_instance) _update_task_statuses_in_db() (server.web.repositories.task_repository.TaskRepository method) _upsert_wf_attribute() (in module server.web.routes.v3.fsm.workflow) _uses_stdlib_integration() (in module core.config.structlog_config) _val_fail_after_n_executions (client.swarm.workflow_run.WorkflowRun attribute) _validate_status_transition() (client.swarm.workflow_run.WorkflowRun method) _validate_task_function() (core.task_generator.TaskGenerator method) _validate_transition() (server.web.models.task.Task method) (server.web.models.task_instance.TaskInstance method) (server.web.models.workflow.Workflow method) (server.web.models.workflow_run.WorkflowRun method) _version (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _wf_notification_sink (server.workflow_reaper.workflow_reaper.WorkflowReaper attribute) _worker_node_entry_point (dummy.dummy_distributor.DummyDistributor attribute) (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) (sequential.seq_distributor.SequentialDistributor attribute) _worker_node_interface (worker_node.worker_node_factory.WorkerNodeFactory attribute) _workflow_run_id (client.workflow.DistributorContext attribute) (client.workflow_run.WorkflowRun attribute) _wrap_print_logger_factory() (in module core.config.structlog_config) _wrap_wrapper_class_for_otlp() (in module core.config.structlog_config) _wrapped_get() (core.configuration.JobmonConfig method) _wrapper_indicates_direct_rendering() (in module core.config.structlog_config) _yaml_file (core.task_generator.TaskGenerator attribute) _zip_collection_items_and_types() (in module core.task_generator)

A

ABORTED (core.constants.WorkflowRunStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) active_states (server.web.models.workflow_run.WorkflowRun attribute) ACTIVE_TASK_STATUSES (in module client.swarm.workflow_run) active_task_template_version (client.task_template.TaskTemplate property) active_task_templates (client.tool.Tool property) active_tasks (client.swarm.workflow_run.WorkflowRun property) active_tool_version (client.tool.Tool property) add_arg_types() (in module server.web.models.arg_type) add_array() (in module server.web.routes.v3.fsm.array) add_attribute() (client.task.Task method) add_attributes() (client.workflow.Workflow method) add_cluster_types() (in module server.web.models.cluster_type) add_clusters() (in module server.web.models.cluster) add_dag() (in module server.web.routes.v3.fsm.dag) add_downstream() (client.task.Task method) add_downstream_node() (client.node.Node method) add_downstream_nodes() (client.node.Node method) add_downstreams() (client.task.Task method) add_edges() (in module server.web.routes.v3.fsm.dag) add_hooks_and_handlers() (in module server.web.hooks_and_handlers) add_node() (client.dag.Dag method) add_nodes() (in module server.web.routes.v3.fsm.node) add_queues() (in module server.web.models.queue) add_server_structlog_context() (core.requester.Requester method) add_span_details_processor() (in module core.otlp) (in module core.otlp.formatters) (in module core.otlp.utils) add_string_length_constraint() (in module server.web.models) add_task() (client.array.Array method) (client.swarm.swarm_array.SwarmArray method) (client.workflow.Workflow method) add_task_attributes() (in module client.attributes) add_task_instance() (distributor.task_instance_batch.TaskInstanceBatch method) add_task_instance_statuses() (in module server.web.models.task_instance_status) add_task_resources_types() (in module server.web.models.task_resources_type) add_task_statuses() (in module server.web.models.task_status) add_task_template_version() (in module server.web.routes.v3.fsm.task_template) add_tasks() (client.workflow.Workflow method) add_time() (in module server.web._compat) add_time_expr() (in module server.web.utils) (in module server.web.utils.time_sql) add_tool() (in module server.web.routes.v3.fsm.tool) add_tool_version() (in module server.web.routes.v3.fsm.tool_version) add_upstream() (client.task.Task method) add_upstream_node() (client.node.Node method) add_upstream_nodes() (client.node.Node method) add_upstreams() (client.task.Task method) add_workflow_run() (in module server.web.routes.v3.fsm.workflow_run) add_workflow_run_statuses() (in module server.web.models.workflow_run_status) add_workflow_statuses() (in module server.web.models.workflow_status) adjust_resources() (client.task_resources.TaskResources method)

ADJUSTED (core.constants.TaskResourcesType attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) ADJUSTING_RESOURCES (core.constants.TaskStatus attribute) (server.web.models.task_status.TaskStatus attribute) alive() (client.workflow.DistributorContext method) all_upstreams_done (client.swarm.swarm_task.SwarmTask property) api_auth_router (in module server.web.routes.auth) api_url (server.workflow_reaper.notifiers.SlackNotifier attribute) api_v3_health_router (in module server.web.routes.v3) api_v3_router (in module server.web.routes.v3) api_version() (in module server.web.routes.v3) apply_migrations() (in module server.web.db) (in module server.web.db.migrate) Arg (class in server.web.models.arg) arg_id (server.web.models.node_arg.NodeArg attribute) (server.web.models.task_arg.TaskArg attribute) (server.web.models.template_arg_map.TemplateArgMap attribute) arg_mapping_hash (client.task_template_version.TaskTemplateVersion property) (server.web.models.task_template_version.TaskTemplateVersion attribute) arg_type_id (server.web.models.template_arg_map.TemplateArgMap attribute) ArgType (class in core.constants) (class in server.web.models.arg_type) argument (server.web.models.template_arg_map.TemplateArgMap attribute) argument_type (server.web.models.template_arg_map.TemplateArgMap attribute) Array (class in client.array) (class in server.web.models.array) array (client.task.Task property) (server.web.models.task.Task attribute) array_batch_num (server.web.models.task_instance.TaskInstance attribute) array_id (client.array.Array property) (client.swarm.swarm_array.SwarmArray attribute) (client.swarm.swarm_task.SwarmTask attribute) (distributor.task_instance_batch.TaskInstanceBatch attribute) (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) array_name (client.swarm.swarm_array.SwarmArray attribute) (distributor.task_instance_batch.TaskInstanceBatch attribute) ARRAY_NAME (server.web.schemas.array.ArrayTaskInstance attribute) array_step_id (core.cluster_protocol.ClusterWorkerNode property) (distributor.distributor_task_instance.DistributorTaskInstance property) (multiprocess.multiproc_distributor.MultiprocessWorkerNode property) (server.web.models.task_instance.TaskInstance attribute) array_tasks (server.web.schemas.array.ArrayTasksResponse attribute) ArrayRepository (class in server.web.repositories.array_repository) arrays (client.swarm.workflow_run.WorkflowRun attribute) (client.workflow.Workflow attribute) ArrayTaskInstance (class in server.web.schemas.array) ArrayTasksResponse (class in server.web.schemas.array) at_hash (server.web.routes.utils.User attribute) attempt_number_of_instance (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) aud (server.web.routes.utils.User attribute) auth() (in module server.web.routes.auth.oidc.oidc) avg (server.web.schemas.task_template.CoreInfoItem attribute)

B

Base (class in server.web.models) base_chart_to_B (client.units.MemUnit attribute) BaseJobmonResourceDetector (class in core.otlp.resources) batch (distributor.distributor_task_instance.DistributorTaskInstance property) batch_number (distributor.task_instance_batch.TaskInstanceBatch attribute) bind() (client.array.Array method) (client.dag.Dag method) (client.task_resources.TaskResources method) (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.workflow.Workflow method) (client.workflow_run.WorkflowRun method) (core.cluster.Cluster method)

bind_context() (in module core.structlog_utils) bind_jobmon_context() (in module core.logging) (in module core.logging.context) bind_method_context() (in module core.structlog_utils) bind_task_args() (in module server.web.routes.v3.fsm.task) bind_task_attributes() (in module server.web.routes.v3.fsm.task) bind_task_resources() (in module server.web.routes.v3.fsm.task) bind_tasks_no_args() (in module server.web.routes.v3.fsm.task) bind_workflow() (in module server.web.routes.v3.fsm.workflow) BOUND (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) bound_error_states (server.web.models.workflow_run.WorkflowRun attribute) build_worker_node_command() (core.cluster_protocol.ClusterDistributor method) BUILT_IN_COLLECTIONS (in module core.task_generator)

C

calculate_resource_statistics() (server.web.repositories.task_template_repository.TaskTemplateRepository method) CallableReturnedInvalidObject channel_default (server.workflow_reaper.notifiers.SlackNotifier attribute) ci (server.web.schemas.task_template.TaskTemplateResourceUsageRequest attribute) ci_mem (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) ci_runtime (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) clear_dns_cache() (in module server.web.db.dns) clear_jobmon_context() (in module core.logging) (in module core.logging.context) CLI (class in core.cli) cli_router (in module server.web.routes.v3.cli) client module client.api module client.array module client.attributes module client.cli module client.config module client.dag module client.logging module client.node module client.status_commands module client.swarm module client.swarm.swarm_array module client.swarm.swarm_task module client.swarm.workflow_run module client.task module client.task_resources module client.task_template module client.task_template_version module client.tool module client.tool_version module client.units module client.workflow module client.workflow_run module ClientCLI (class in client.cli) close() (core.otlp.handlers.JobmonOTLPLoggingHandler method) (core.otlp.JobmonOTLPLoggingHandler method) Cluster (class in core.cluster) (class in server.web.models.cluster) cluster (client.swarm.swarm_task.SwarmTask attribute) (server.web.models.queue.Queue attribute) cluster_distributor_class (core.cluster_type.ClusterType property) cluster_error_logs() (in module server.web.error_log_clustering) cluster_id (server.web.models.queue.Queue attribute) cluster_interface (distributor.distributor_service.DistributorService attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) cluster_name (client.array.Array property) (client.task.Task property) (core.cluster.Cluster attribute) (core.cluster_protocol.ClusterDistributor property) (dummy.dummy_distributor.DummyDistributor property) (multiprocess.multiproc_distributor.MultiprocessDistributor property) (sequential.seq_distributor.SequentialDistributor property) cluster_queue_class (core.cluster_type.ClusterType property) cluster_type (server.web.models.cluster.Cluster attribute) cluster_type_id (server.web.models.cluster.Cluster attribute) cluster_type_name (core.cluster_type.ClusterType attribute) cluster_worker_node_class (core.cluster_type.ClusterType property) ClusterDistributor (class in core.cluster_protocol) ClusterQueue (class in core.cluster_protocol) clusters (server.web.models.cluster_type.ClusterType attribute) ClusterType (class in core.cluster_type) (class in server.web.models.cluster_type) ClusterWorkerNode (class in core.cluster_protocol) coerce_resources() (client.task_resources.TaskResources method) (core.cluster_protocol.ClusterQueue method) (dummy.dummy_queue.DummyQueue method) (multiprocess.multiproc_queue.MultiprocessQueue method) (sequential.seq_queue.SequentialQueue method) cold_reset() (server.web.models.workflow_run.WorkflowRun method) COLD_RESUME (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) command (client.task.Task attribute) (multiprocess.multiproc_distributor.PickableTask attribute) (server.web.models.task.Task attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) command_add_env (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) command_returncode (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) command_stderr (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) command_stdout (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) command_template (client.task_template_version.TaskTemplateVersion attribute) (server.web.models.task_template_version.TaskTemplateVersion attribute)

component_name (core.cli.CLI attribute) compute_resources (client.array.Array property) (client.task.Task property) compute_resources_callable (client.array.Array attribute) (client.swarm.swarm_task.SwarmTask attribute) (client.task.Task property) concurrency_limit() (client.cli.ClientCLI static method) (in module client.status_commands) config (in module server.web.auth) CONFIG_FILE_FROM_INSTALLER_PLUGIN (in module core) ConfigCLI (class in core.configuration) ConfigError configure_client_logging() (in module client.logging) configure_component_logging() (core.cli.CLI method) (in module core.config.logconfig_utils) configure_logging_with_overrides() (in module core.config) (in module core.config.logconfig_utils) configure_server_logging() (in module server.web.logging) configure_structlog() (in module core.config.structlog_config) configure_structlog_with_otlp() (in module core.config.structlog_config) connection_parameters (core.cluster.Cluster property) (server.web.models.cluster.Cluster attribute) Consumer (class in multiprocess.multiproc_distributor) consumers (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) convert() (client.units.MemUnit static method) convert_arg_names_to_ids() (client.task_template_version.TaskTemplateVersion method) convert_memory_to_gib() (client.task_resources.TaskResources static method) convert_runtime_to_s() (client.task_resources.TaskResources static method) core module core.cli module core.cluster module core.cluster_protocol module core.cluster_type module core.config module core.config.logconfig_utils module core.config.structlog_config module core.config.structlog_formatters module core.config.template_loader module core.config.templates module core.configuration module core.constants module core.exceptions module core.jobmon_utils module core.logging module core.logging.context module core.otlp module core.otlp.formatters module core.otlp.handlers module core.otlp.manager module core.otlp.resources module core.otlp.utils module core.requester module core.serializers module core.structlog_utils module core.task_generator module core_info (server.web.schemas.task_template.RequestedCoresResponse attribute) CoreInfoItem (class in server.web.schemas.task_template) cores (server.web.schemas.task_template.RequestedResourcesModel attribute) cpu (server.web.models.task_instance.TaskInstance attribute) create_anonymous_user() (in module server.web.routes.utils) create_jobmon_resources() (in module core.otlp.resources) create_log_exporter() (in module core.otlp.manager) create_resource_yaml() (in module client.status_commands) create_response() (in module server.web.routes.v3.cli.task) create_task() (client.task_template.TaskTemplate method) (core.task_generator.TaskGenerator method) create_task_name() (in module core.task_generator) create_tasks() (client.array.Array method) (client.task_template.TaskTemplate method) (core.task_generator.TaskGenerator method) create_telemetry_isolation_processor() (in module core.config.structlog_config) create_workflow() (client.tool.Tool method) create_workflow_run() (client.workflow_run.WorkflowRunFactory method) created_date (server.web.models.array.Array attribute) (server.web.models.dag.Dag attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run.WorkflowRun attribute) CSP (in module server.web.middleware.security_headers) csp (server.web.middleware.security_headers.SecurityHeadersMiddleware attribute) current_task_resources (client.swarm.swarm_task.SwarmTask attribute) CyclicGraphError

D

DAG Dag (class in client.dag) (class in server.web.models.dag) dag (server.web.models.workflow.Workflow attribute) dag_id (client.dag.Dag property) (client.workflow.Workflow property) (server.web.models.edge.Edge attribute) (server.web.models.workflow.Workflow attribute) (server.web.schemas.task.DownstreamTasksRequest attribute) date_submitted (server.web.schemas.workflow.WorkflowOverviewRequest attribute) date_submitted_end (server.web.schemas.workflow.WorkflowOverviewRequest attribute) DB (in module server.web.db) (in module server.web.db.deps) default_cluster_name (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion attribute) (client.tool.Tool property) (client.tool_version.ToolVersion attribute) (client.workflow.Workflow attribute) default_compute_resources_set (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion attribute) (client.tool.Tool property) (client.tool_version.ToolVersion attribute) (client.workflow.Workflow attribute) default_config (in module client.logging) (in module server.web.logging) default_max_attempt (client.tool_version.ToolVersion attribute) default_max_attempts (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion attribute) (client.tool.Tool property) (client.workflow.Workflow property) default_name (client.node.Node property) default_resource_scales_set (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion attribute) (client.tool.Tool property) (client.tool_version.ToolVersion attribute) (client.workflow.Workflow attribute) DEFAULTS_FILE (in module core.configuration) DEFAULTS_FILE_NAME (in module core.configuration) derive_jobmon_command_from_env() (client.workflow.DistributorContext static method) description (client.workflow.Workflow attribute) (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) deserialize() (core.task_generator.TaskGenerator method) detect() (core.otlp.resources.BaseJobmonResourceDetector method) DIALECT (in module server.web._compat) (in module server.web.routes.v3.cli.task_template) (in module server.web.routes.v3.fsm.dag) (in module server.web.routes.v3.fsm.node) (in module server.web.routes.v3.fsm.task) (in module server.web.routes.v3.fsm.workflow) (in module server.web.utils.time_sql) Direction (class in core.constants) disable_structlog_otlp_capture() (in module core.config.structlog_config) dispatch() (server.web.middleware.security_headers.SecurityHeadersMiddleware method) Distributor distributor module distributor.api module

distributor.cli module distributor.config module distributor.distributor_command module distributor.distributor_service module distributor.distributor_task_instance module distributor.distributor_workflow_run module distributor.task_instance_batch module distributor_id (core.cluster_protocol.ClusterWorkerNode property) (distributor.distributor_task_instance.DistributorTaskInstance property) (dummy.dummy_distributor.DummyWorkerNode property) (multiprocess.multiproc_distributor.MultiprocessWorkerNode property) (multiprocess.multiproc_distributor.PickableTask attribute) (sequential.seq_distributor.SequentialWorkerNode property) (server.web.models.task_instance.TaskInstance attribute) DISTRIBUTOR_ID (server.web.schemas.task.TaskStatusItem attribute) distributor_id (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) DistributorCLI (class in distributor.cli) DistributorCommand (class in distributor.distributor_command) DistributorContext (class in client.workflow) DistributorInterruptedError DistributorNotAlive DistributorService (class in distributor.distributor_service) DistributorStartupTimeout DistributorTaskInstance (class in distributor.distributor_task_instance) DistributorUnexpected DistributorWorkflowRun (class in distributor.distributor_workflow_run) DONE (core.constants.TaskInstanceStatus attribute) (core.constants.TaskStatus attribute) (core.constants.WorkflowRunStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) done_tasks (client.swarm.workflow_run.WorkflowRun property) DOWN (core.constants.Direction attribute) down (server.web.schemas.task.TaskDependenciesResponse attribute) downstream_node_ids (server.web.models.edge.Edge attribute) downstream_nodes (client.node.Node attribute) downstream_swarm_tasks (client.swarm.swarm_task.SwarmTask attribute) downstream_tasks (client.swarm.swarm_task.SwarmTask property) (client.task.Task attribute) (server.web.schemas.task.DownstreamTasksResponse attribute) DownstreamTasksRequest (class in server.web.schemas.task) DownstreamTasksResponse (class in server.web.schemas.task) dummy module dummy.dummy_distributor module dummy.dummy_queue module DummyDistributor (class in dummy.dummy_distributor) DummyQueue (class in dummy.dummy_queue) DummyWorkerNode (class in dummy.dummy_distributor) DuplicateNodeArgsError

E

Edge (class in server.web.models.edge) email (server.web.routes.utils.User attribute) emit() (core.otlp.handlers.JobmonOTLPLoggingHandler method) (core.otlp.JobmonOTLPLoggingHandler method) EmptyWorkflowError enable_structlog_otlp_capture() (in module core.config.structlog_config) ensure_json_compatible_format() (in module server.web.utils.json_compat) ensure_structlog_configured() (in module client.logging) ENV_VAR_PREFIX (in module core.configuration) ERROR (core.constants.TaskInstanceStatus attribute) (core.constants.WorkflowRunStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) error (server.web.schemas.task_template.ErrorLogItem attribute) ERROR_FATAL (core.constants.TaskInstanceStatus attribute) (core.constants.TaskStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute)

error_logs (server.web.schemas.task_template.ErrorLogResponse attribute) error_msg (distributor.distributor_task_instance.DistributorTaskInstance attribute) ERROR_PATH (server.web.schemas.array.ArrayTaskInstance attribute) error_raised (distributor.distributor_command.DistributorCommand attribute) ERROR_RECOVERABLE (core.constants.TaskStatus attribute) (server.web.models.task_status.TaskStatus attribute) error_score (server.web.schemas.task_template.ErrorLogItem attribute) error_state (distributor.distributor_task_instance.DistributorTaskInstance attribute) error_states (server.web.models.task_instance.TaskInstance attribute) error_time (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) (server.web.schemas.task_template.ErrorLogItem attribute) ERROR_TRACE (server.web.schemas.task.TaskStatusItem attribute) ErrorLogItem (class in server.web.schemas.task_template) ErrorLogResponse (class in server.web.schemas.task_template) errors (server.web.models.task_instance.TaskInstance attribute) EXECLUDE_TTVS (core.constants.ExecludeTTVs attribute) ExecludeTTVs (class in core.constants) exp (server.web.routes.utils.User attribute) expand_dict() (client.array.Array static method)

F

F (in module core.structlog_utils) fail_fast (client.swarm.workflow_run.WorkflowRun attribute) FAILED (core.constants.WorkflowStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) failed_tasks (client.swarm.workflow_run.WorkflowRun property) fallback_queues (client.swarm.swarm_task.SwarmTask attribute) (client.task.Task attribute) (server.web.models.task.Task attribute) family_name (server.web.routes.utils.User attribute) FATAL (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) fetch_workflow_metadata() (in module server.web.routes.v3.fsm.workflow) filter_kwargs() (client.task_template_version.TaskTemplateVersion method) final_argument_whitespace (core.task_generator.TaskGeneratorDocumenter attribute) (core.task_generator.TaskGeneratorModuleDocumenter attribute) final_status (client.task.Task property) first_error_time (server.web.schemas.task_template.ErrorLogItem attribute) fix_wf_inconsistency() (in module server.web.routes.v3.reaper.reaper)

flush_and_shutdown() (core.otlp.manager.JobmonOTLPManager method) format() (core.config.structlog_formatters.JobmonStructlogEventOnlyFormatter method) (core.otlp.formatters.JobmonOTLPFormatter method) (core.otlp.JobmonOTLPFormatter method) (core.otlp.utils.JobmonOTLPFormatter method) formatted_stats() (server.web.schemas.task_template.TaskTemplateResourceUsageResponse method) from_defaults() (core.requester.Requester class method) from_wire() (client.task_template.TaskTemplate class method) (client.task_template_version.TaskTemplateVersion class method) (client.tool_version.ToolVersion class method) (server.web.models.task_attribute.TaskAttribute class method) (server.web.models.task_attribute_type.TaskAttributeType class method) (server.web.models.workflow_attribute.WorkflowAttribute class method) (server.web.models.workflow_attribute_type.WorkflowAttributeType class method) (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun class method) from_workflow() (client.swarm.workflow_run.WorkflowRun method) from_workflow_id() (client.swarm.workflow_run.WorkflowRun method) fsm_router (in module server.web.routes.v3.fsm) full_path (core.task_generator.TaskGenerator attribute)

G

get() (core.configuration.JobmonConfig method) get_app() (in module server.web.api) get_array_max_concurrently_running() (in module server.web.routes.v3.fsm.array) get_array_queueing_errors() (dummy.dummy_distributor.DummyDistributor method) (sequential.seq_distributor.SequentialDistributor method) get_array_task_instance() (worker_node.worker_node_factory.WorkerNodeFactory method) get_array_task_instance_id() (in module server.web.routes.v3.fsm.task_instance) get_array_task_instances() (in module server.web.routes.v3.cli.array) get_array_tasks() (server.web.repositories.array_repository.ArrayRepository method) get_available_workflow_statuses() (in module server.web.routes.v3.fsm.workflow) get_boolean() (core.configuration.JobmonConfig method) get_client_compatibility_mode() (in module server.web.utils.json_compat) get_cluster() (core.cluster.Cluster class method) get_cluster_by_name() (client.workflow.Workflow method) (in module server.web.routes.v3.fsm.cluster) get_cluster_distributor_class() (in module dummy) (in module multiprocess) (in module sequential) get_cluster_queue_class() (in module dummy) (in module multiprocess) (in module sequential) get_cluster_worker_node_class() (in module dummy) (in module multiprocess) (in module sequential) get_content() (in module core.requester) get_core_templates_path() (in module core.config.template_loader) get_current_span_details() (in module core.otlp) (in module core.otlp.formatters) (in module core.otlp.utils) get_db() (in module server.web.db) (in module server.web.db.deps) get_dialect_name() (in module server.web.db) (in module server.web.db.engine) get_distributor() (core.cluster.Cluster method) get_dns_engine() (in module server.web.db.dns) get_downstream_tasks() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_engine() (in module server.web.db) (in module server.web.db.engine) get_errors() (client.task.Task method) (client.workflow.Workflow method) get_exit_info() (core.cluster_protocol.ClusterWorkerNode method) (dummy.dummy_distributor.DummyWorkerNode static method) (multiprocess.multiproc_distributor.MultiprocessWorkerNode method) (sequential.seq_distributor.SequentialWorkerNode static method) get_filepaths() (client.cli.ClientCLI static method) (in module client.status_commands) get_float() (core.configuration.JobmonConfig method) get_instance() (core.otlp.manager.JobmonOTLPManager class method) get_int() (core.configuration.JobmonConfig method) get_ip_with_ttl() (in module server.web.db.dns) get_job_task_instance() (worker_node.worker_node_factory.WorkerNodeFactory method) get_jobmon_config() (in module server.web.config) get_jobmon_context() (in module core.logging) (in module core.logging.context) get_logconfig_examples() (in module core.config) (in module core.config.logconfig_utils) get_logger() (in module core.otlp.manager) get_lost_workflow_runs() (in module server.web.routes.v3.reaper.reaper) get_matching_workflows_by_workflow_args() (in module server.web.routes.v3.fsm.workflow) get_max_concurrently_running() (in module server.web.routes.v3.fsm.workflow) get_most_popular_queue() (in module server.web.routes.v3.cli.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_most_recent_ti_error() (in module server.web.routes.v3.fsm.task) get_new_task_status() (in module server.web.routes.v3.fsm.task_instance) get_new_tool_version() (client.tool.Tool method) get_optional_type_parameter() (in module core.task_generator) get_pst_now() (in module server.web.routes) (in module server.web.routes.v3) get_queue() (core.cluster.Cluster method) get_queue_by_cluster_queue_names() (in module server.web.routes.v3.fsm.queue) get_queueing_errors() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) get_remote_exit_info() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) get_request_username() (in module server.web.routes.utils) get_requested_cores() (in module server.web.routes.v3.cli.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_section() (core.configuration.JobmonConfig method) get_section_coerced() (core.configuration.JobmonConfig method)

get_server_otlp_manager() (in module server.web.otlp) (in module server.web.otlp.manager) get_sessionmaker() (in module server.web.db) (in module server.web.db.engine) get_shared_logger_provider() (in module core.otlp.manager) get_sub_task_tree() (in module client.status_commands) get_submitted_or_running() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) get_swarm_commands() (client.swarm.workflow_run.WorkflowRun method) get_task_dependencies() (in module client.status_commands) (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_task_details() (in module server.web.routes.v3.cli.task) get_task_details_by_workflow_id() (server.web.repositories.workflow_repository.WorkflowRepository method) get_task_details_viz() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_task_instance_details() (server.web.repositories.task_repository.TaskRepository method) get_task_instance_error_log() (in module server.web.routes.v3.fsm.task_instance) get_task_resource_details() (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_task_resource_usage() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_task_resources() (in module server.web.routes.v3.fsm.task_resources) get_task_status() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_task_subdag() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) get_task_template() (client.task_template.TaskTemplate class method) (client.tool.Tool method) (client.tool_version.ToolVersion method) (in module server.web.routes.v3.fsm.task_template) get_task_template_details() (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_task_template_details_for_workflow() (in module server.web.routes.v3.cli.task_template) get_task_template_id_for_task_template_version() (in module server.web.routes.v3.fsm.task_template) get_task_template_resource_usage() (in module server.web.routes.v3.cli.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_task_template_version() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion class method) get_task_template_version_for_tasks() (in module server.web.routes.v3.cli.task_template) get_task_template_versions() (in module server.web.routes.v3.fsm.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_task_templates() (in module server.web.routes.v3.fsm.tool_version) get_tasks_by_node_args() (client.array.Array method) (client.workflow.Workflow method) (in module core.task_generator) get_tasks_from_workflow() (in module server.web.routes.v3.fsm.workflow) get_tasks_recursive() (in module server.web.routes.v3.cli.task) get_tool_resource_usage() (in module server.web.routes.v3.fsm.tool) get_tool_version() (client.tool_version.ToolVersion class method) get_tool_versions() (in module server.web.routes.v3.fsm.tool) get_tracer() (core.otlp.manager.JobmonOTLPManager method) (server.web.otlp.manager.ServerOTLPManager method) (server.web.otlp.ServerOTLPManager method) get_transit_status() (in module server.web.routes.v3.fsm.task_instance) get_tt_error_log_viz() (in module server.web.routes.v3.cli.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_usage_stats() (core.cluster_protocol.ClusterWorkerNode method) (dummy.dummy_distributor.DummyWorkerNode static method) (multiprocess.multiproc_distributor.MultiprocessWorkerNode method) (sequential.seq_distributor.SequentialWorkerNode static method) get_user() (in module server.web.routes.utils) get_user_or_anonymous() (in module server.web.routes.utils) get_wf_name_and_args() (in module server.web.routes.v3.reaper.reaper) get_worker_node() (core.cluster.Cluster method) get_workflow_details_by_id() (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_overview() (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_run_for_reset() (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_run_for_workflow_reset() (in module server.web.routes.v3.cli.workflow) get_workflow_status() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_status_viz() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_tasks() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_tt_status_viz() (in module server.web.routes.v3.cli.task_template) (server.web.repositories.task_template_repository.TaskTemplateRepository method) get_workflow_user_validation() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) get_workflow_validation_status() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) given_name (server.web.routes.utils.User attribute) group_instance_count (server.web.schemas.task_template.ErrorLogItem attribute) groups (server.web.routes.utils.User attribute)

H

HALTED (core.constants.WorkflowStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) hash (server.web.models.dag.Dag attribute) health() (in module server.web.routes) (in module server.web.routes.v3) heartbeat() (server.web.models.workflow_run.WorkflowRun method) heartbeat_date (server.web.models.workflow_run.WorkflowRun attribute) heartbeat_interval (client.workflow_run.WorkflowRun attribute) heartbeat_report_by_buffer (client.workflow_run.WorkflowRun attribute)

help() (core.task_generator.TaskGenerator method) HELP_TEXT_INTRO_FORMAT (in module core.task_generator) HostResourceDetector (class in core.otlp.resources) hot_reset() (server.web.models.workflow_run.WorkflowRun method) HOT_RESUME (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) hour_to_min() (client.units.TimeUnit static method) hour_to_sec() (client.units.TimeUnit static method) hours (client.units.TimeUnit attribute) http_request_ok() (in module core.requester)

I

iat (server.web.routes.utils.User attribute) id (client.task_resources.TaskResources property) (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion property) (client.tool_version.ToolVersion attribute) (core.cluster.Cluster property) (server.web.models.arg.Arg attribute) (server.web.models.arg_type.ArgType attribute) (server.web.models.array.Array attribute) (server.web.models.cluster.Cluster attribute) (server.web.models.cluster_type.ClusterType attribute) (server.web.models.dag.Dag attribute) (server.web.models.node.Node attribute) (server.web.models.queue.Queue attribute) (server.web.models.task.Task attribute) (server.web.models.task_attribute_type.TaskAttributeType attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_resources.TaskResources attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.task_template.TaskTemplate attribute) (server.web.models.task_template_version.TaskTemplateVersion attribute) (server.web.models.tool.Tool attribute) (server.web.models.tool_version.ToolVersion attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_attribute_type.WorkflowAttributeType attribute) (server.web.models.workflow_run.WorkflowRun attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) (server.web.schemas.task.TaskDependencyItem attribute) (server.web.schemas.task_template.CoreInfoItem attribute) (server.web.schemas.task_template.QueueInfoItem attribute) (server.web.schemas.task_template.TaskTemplateVersionItem attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) id_name_map (client.task_template_version.TaskTemplateVersion property) ILLEGAL_SPECIAL_CHARACTERS (core.constants.SpecialChars attribute) include_constructor() (in module core.config.template_loader) init_db() (in module server.web.db) (in module server.web.db.migrate) (server.cli.ServerCLI method) initial_status (client.task.Task property) initialize() (core.otlp.manager.JobmonOTLPManager method) (server.web.otlp.manager.ServerOTLPManager method) (server.web.otlp.ServerOTLPManager method) initialize_jobmon_otlp() (in module core.otlp.manager) initialize_logfile() (core.cluster_protocol.ClusterWorkerNode method) (dummy.dummy_distributor.DummyWorkerNode method) (multiprocess.multiproc_distributor.MultiprocessWorkerNode method) (sequential.seq_distributor.SequentialWorkerNode method) initialize_server_otlp() (in module server.web.otlp) (in module server.web.otlp.manager)

initialized (client.swarm.workflow_run.WorkflowRun attribute) instantiate_task_instances() (distributor.distributor_service.DistributorService method) (in module server.web.routes.v3.fsm.task_instance) INSTANTIATED (core.constants.TaskInstanceStatus attribute) (core.constants.WorkflowRunStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) INSTANTIATING (core.constants.TaskStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) instrument_app() (server.web.otlp.manager.ServerOTLPManager method) (server.web.otlp.ServerOTLPManager method) instrument_engine() (server.web.otlp.manager.ServerOTLPManager class method) (server.web.otlp.ServerOTLPManager class method) instrument_requests() (core.otlp.manager.JobmonOTLPManager class method) (server.web.otlp.manager.ServerOTLPManager class method) (server.web.otlp.ServerOTLPManager class method) instrument_sqlalchemy() (server.web.otlp.manager.ServerOTLPManager class method) (server.web.otlp.ServerOTLPManager class method) InvalidMemoryFormat InvalidMemoryUnit InvalidRequest InvalidResponse InvalidStateTransition InvalidToolError InvalidToolVersionError InvalidUsage io (server.web.models.task_instance.TaskInstance attribute) is_active (server.web.models.workflow_run.WorkflowRun property) is_alive (server.web.models.workflow_run.WorkflowRun property) is_alive() (in module server.web.routes) (in module server.web.routes.v3) is_auth_enabled() (in module server.web.auth) (in module server.web.routes.utils) is_bound (client.array.Array property) (client.task.Task property) (client.task_resources.TaskResources property) (client.task_template.TaskTemplate property) (client.task_template_version.TaskTemplateVersion property) (client.workflow.Workflow property) (core.cluster.Cluster property) is_mysql() (in module server.web.db) (in module server.web.db.engine) is_optional_type() (in module core.task_generator) is_resumable (server.web.models.workflow.Workflow property) is_sqlite() (in module server.web.db) (in module server.web.db.engine) is_structlog_configured() (in module core.config.structlog_config) is_super_user() (in module server.web.routes.utils) is_valid_job_name() (client.task.Task static method) iss (server.web.routes.utils.User attribute)

J

jobmon_server_version (server.web.models.workflow_run.WorkflowRun attribute) jobmon_version (server.web.models.workflow_run.WorkflowRun attribute) jobmon_version() (client.cli.ClientCLI static method) JobmonConfig (class in core.configuration) JobmonOTLPFormatter (class in core.otlp) (class in core.otlp.formatters) (class in core.otlp.utils)

JobmonOTLPLoggingHandler (class in core.otlp) (class in core.otlp.handlers) JobmonOTLPManager (class in core.otlp.manager) JobmonOTLPStructlogHandler (class in core.otlp) (class in core.otlp.handlers) JobmonServiceResourceDetector (class in core.otlp.resources) JobmonStructlogEventOnlyFormatter (class in core.config.structlog_formatters) JSON_COMPAT_CUTOFF_VERSION (in module server.web.utils.json_compat)

K

KILL_SELF (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) kill_self_batch() (distributor.distributor_service.DistributorService method) kwargs_from_wire() (core.serializers.SerializeClientTaskTemplate static method) (core.serializers.SerializeClientTaskTemplateVersion static method) (core.serializers.SerializeClientTool static method) (core.serializers.SerializeClientToolVersion static method) (core.serializers.SerializeCluster static method) (core.serializers.SerializeClusterType static method) (core.serializers.SerializeDistributorArray static method) (core.serializers.SerializeDistributorTask static method) (core.serializers.SerializeDistributorWorkflow static method) (core.serializers.SerializeExecutorTaskInstanceErrorLog static method) (core.serializers.SerializeQueue static method) (core.serializers.SerializeSwarmTask static method) (core.serializers.SerializeTaskInstanceBatch static method) (core.serializers.SerializeTaskInstanceErrorLog static method) (core.serializers.SerializeTaskResources static method) (core.serializers.SerializeTaskResourceUsage static method) (core.serializers.SerializeTaskTemplateResourceUsage static method) (core.serializers.SerializeWorkflowRun static method)

kwargs_from_wire_distributor() (core.serializers.SerializeTaskInstance static method) kwargs_from_wire_worker_node() (core.serializers.SerializeTaskInstance static method)

L

label (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) LABEL_DICT (core.constants.TaskStatus attribute) last_heartbeat_time (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) last_workflow_run_id (client.workflow.Workflow attribute) launch_task_instance() (distributor.distributor_service.DistributorService method) launch_task_instance_batch() (distributor.distributor_service.DistributorService method) LAUNCHED (core.constants.TaskInstanceStatus attribute) (core.constants.TaskStatus attribute) (core.constants.WorkflowRunStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) limit_checker() (client.cli.ClientCLI static method) LimitedSizeDict (class in dummy.dummy_distributor) (class in sequential.seq_distributor) link_workflow_run() (server.web.models.workflow.Workflow method) LINKING (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) load_all_templates() (in module core.config.template_loader) load_logconfig_with_overrides() (in module core.config) (in module core.config.logconfig_utils) load_logconfig_with_templates() (in module core.config) (in module core.config.template_loader) load_metadata() (in module server.web.models) load_model() (in module server.web.models) load_requested_resources() (distributor.task_instance_batch.TaskInstanceBatch method) load_task_template_versions() (client.task_template.TaskTemplate method) load_task_templates() (client.tool_version.ToolVersion method) load_yaml_with_templates() (in module core.config) (in module core.config.template_loader) log (in module server.web.auth) (in module server.web.db.engine) log_array_distributor_id() (in module server.web.routes.v3.fsm.array) log_distributor_id() (in module server.web.routes.v3.fsm.task_instance) log_distributor_ids() (distributor.task_instance_batch.TaskInstanceBatch method) log_done() (in module server.web.routes.v3.fsm.task_instance) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) log_error() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) log_error_worker_node() (in module server.web.routes.v3.fsm.task_instance) log_known_error() (in module server.web.routes.v3.fsm.task_instance) log_no_distributor_id() (in module server.web.routes.v3.fsm.task_instance) log_report_by() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) log_running() (in module server.web.routes.v3.fsm.task_instance) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) log_task_instance_report_by_date() (distributor.distributor_service.DistributorService method) log_ti_report_by() (in module server.web.routes.v3.fsm.task_instance) log_ti_report_by_batch() (in module server.web.routes.v3.fsm.task_instance) log_unknown_error() (in module server.web.routes.v3.fsm.task_instance) log_workflow_run_heartbeat() (in module server.web.routes.v3.fsm.workflow_run) log_workflow_run_status_update() (in module server.web.routes.v3.fsm.workflow_run) logfile_templates (server.web.models.cluster_type.ClusterType attribute) logger (in module client.array) (in module client.dag) (in module client.node) (in module client.status_commands) (in module client.swarm.swarm_array) (in module client.swarm.swarm_task) (in module client.swarm.workflow_run) (in module client.task) (in module client.task_resources) (in module client.task_template) (in module client.task_template_version) (in module client.tool) (in module client.tool_version) (in module client.workflow) (in module client.workflow_run) (in module core.cluster) (in module core.requester) (in module core.task_generator) (in module distributor.cli) (in module distributor.distributor_command) (in module distributor.distributor_service) (in module distributor.distributor_task_instance) (in module distributor.distributor_workflow_run) (in module distributor.task_instance_batch) (in module dummy) (in module dummy.dummy_distributor) (in module multiprocess.multiproc_distributor) (in module sequential.seq_distributor) (in module server.cli) (in module server.web.hooks_and_handlers) (in module server.web.models) (in module server.web.models.task) (in module server.web.models.task_instance) (in module server.web.models.workflow) (in module server.web.models.workflow_run) (in module server.web.repositories.array_repository) (in module server.web.repositories.task_repository) (in module server.web.repositories.task_template_repository) (in module server.web.repositories.workflow_repository) (in module server.web.routes) (in module server.web.routes.auth.oidc.oidc) (in module server.web.routes.utils) (in module server.web.routes.v3.cli.task) (in module server.web.routes.v3.cli.task_template) (in module server.web.routes.v3.cli.workflow) (in module server.web.routes.v3.fsm.array) (in module server.web.routes.v3.fsm.dag) (in module server.web.routes.v3.fsm.node) (in module server.web.routes.v3.fsm.task) (in module server.web.routes.v3.fsm.task_instance) (in module server.web.routes.v3.fsm.task_resources) (in module server.web.routes.v3.fsm.task_template) (in module server.web.routes.v3.fsm.tool) (in module server.web.routes.v3.fsm.tool_version) (in module server.web.routes.v3.fsm.workflow) (in module server.web.routes.v3.fsm.workflow_run) (in module server.web.routes.v3.reaper.reaper) (in module server.workflow_reaper.notifiers) (in module server.workflow_reaper.reaper_workflow_run) (in module server.workflow_reaper.workflow_reaper) (in module worker_node.cli) (in module worker_node.worker_node_task_instance)

logger_provider (core.otlp.manager.JobmonOTLPManager attribute) (server.web.otlp.manager.ServerOTLPManager property) (server.web.otlp.ServerOTLPManager property) login() (in module server.web.routes.auth.oidc.oidc) logout() (in module server.web.routes.auth.oidc.oidc)

M

m (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) main module main() (core.cli.CLI method) (in module client.cli) (in module core.configuration) (in module distributor.cli) (in module server.cli) make_cli_argument_string() (in module core.task_generator) mapped_node_args (client.node.Node attribute) mapped_task_args (client.task.Task attribute) max (server.web.schemas.task_template.CoreInfoItem attribute) max_attempts (client.array.Array property) (client.swarm.swarm_task.SwarmTask attribute) (client.task.Task property) (core.task_generator.TaskGenerator attribute) (server.web.models.task.Task attribute) max_concurrently_running (client.array.Array attribute) (client.swarm.swarm_array.SwarmArray attribute) (client.workflow.Workflow attribute) (server.web.models.array.Array attribute) (server.web.models.workflow.Workflow attribute) max_mem (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) max_runtime (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) MAXC (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) MaxConcurrentlyRunning (class in core.constants) MAXCONCURRENTLYRUNNING (core.constants.MaxConcurrentlyRunning attribute) maxpss (server.web.models.task_instance.TaskInstance attribute) maxrss (server.web.models.task_instance.TaskInstance attribute) mean_mem (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) mean_runtime (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) median_mem (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) median_runtime (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) memory (server.web.schemas.task_template.RequestedResourcesModel attribute) MemUnit (class in client.units) merge_logconfig_sections() (in module core.config) (in module core.config.logconfig_utils) min (server.web.schemas.task_template.CoreInfoItem attribute) min_mem (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) min_runtime (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) min_to_hour() (client.units.TimeUnit static method) min_to_sec() (client.units.TimeUnit static method) minutes (client.units.TimeUnit attribute) mod (in module server.web.routes.auth) (in module server.web.routes.v3) mod_name (core.task_generator.TaskGenerator attribute) model_config (server.web.schemas.task_template.ErrorLogItem attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) module client client.api client.array client.attributes client.cli client.config client.dag client.logging client.node client.status_commands client.swarm client.swarm.swarm_array client.swarm.swarm_task client.swarm.workflow_run client.task client.task_resources client.task_template client.task_template_version client.tool client.tool_version client.units client.workflow client.workflow_run core core.cli core.cluster core.cluster_protocol core.cluster_type core.config core.config.logconfig_utils core.config.structlog_config core.config.structlog_formatters core.config.template_loader core.config.templates core.configuration core.constants core.exceptions core.jobmon_utils core.logging core.logging.context core.otlp core.otlp.formatters core.otlp.handlers core.otlp.manager core.otlp.resources core.otlp.utils core.requester core.serializers core.structlog_utils core.task_generator distributor distributor.api distributor.cli distributor.config distributor.distributor_command distributor.distributor_service distributor.distributor_task_instance distributor.distributor_workflow_run distributor.task_instance_batch dummy dummy.dummy_distributor dummy.dummy_queue main multiprocess multiprocess.multiproc_distributor multiprocess.multiproc_queue sequential sequential.seq_distributor sequential.seq_queue server server.cli server.web server.web._compat server.web.api server.web.auth server.web.config server.web.db server.web.db.deps server.web.db.dns server.web.db.engine server.web.db.migrate server.web.error_log_clustering server.web.hooks_and_handlers server.web.logging server.web.middleware server.web.middleware.security_headers server.web.models server.web.models.arg server.web.models.arg_type server.web.models.array server.web.models.cluster server.web.models.cluster_type server.web.models.dag server.web.models.edge server.web.models.node server.web.models.node_arg server.web.models.queue server.web.models.task server.web.models.task_arg server.web.models.task_attribute server.web.models.task_attribute_type server.web.models.task_instance server.web.models.task_instance_error_log server.web.models.task_instance_status server.web.models.task_resources server.web.models.task_resources_type server.web.models.task_status server.web.models.task_template server.web.models.task_template_version server.web.models.template_arg_map server.web.models.tool server.web.models.tool_version server.web.models.workflow server.web.models.workflow_attribute server.web.models.workflow_attribute_type server.web.models.workflow_run server.web.models.workflow_run_status server.web.models.workflow_status server.web.otlp server.web.otlp.manager server.web.repositories server.web.repositories.array_repository server.web.repositories.task_repository server.web.repositories.task_template_repository server.web.repositories.workflow_repository server.web.routes server.web.routes.auth server.web.routes.auth.oidc server.web.routes.auth.oidc.oidc server.web.routes.utils server.web.routes.v3 server.web.routes.v3.cli server.web.routes.v3.cli.array server.web.routes.v3.cli.task server.web.routes.v3.cli.task_template server.web.routes.v3.cli.workflow server.web.routes.v3.fsm server.web.routes.v3.fsm.array server.web.routes.v3.fsm.cluster server.web.routes.v3.fsm.dag server.web.routes.v3.fsm.node server.web.routes.v3.fsm.queue server.web.routes.v3.fsm.task server.web.routes.v3.fsm.task_instance server.web.routes.v3.fsm.task_resources server.web.routes.v3.fsm.task_template server.web.routes.v3.fsm.tool server.web.routes.v3.fsm.tool_version server.web.routes.v3.fsm.workflow server.web.routes.v3.fsm.workflow_run server.web.routes.v3.reaper server.web.routes.v3.reaper.reaper server.web.schemas server.web.schemas.array server.web.schemas.task server.web.schemas.task_template server.web.schemas.workflow server.web.server_side_exception server.web.utils server.web.utils.json_compat server.web.utils.time_sql server.workflow_reaper server.workflow_reaper.api server.workflow_reaper.notifiers server.workflow_reaper.reaper_workflow_run server.workflow_reaper.start server.workflow_reaper.workflow_reaper worker_node worker_node.cli worker_node.config worker_node.worker_node_factory worker_node.worker_node_task_instance

module_source_path (core.task_generator.TaskGenerator attribute) monitor_forever() (server.workflow_reaper.workflow_reaper.WorkflowReaper method) MostPopularQueueResponse (class in server.web.schemas.task_template) msg (server.web.server_side_exception.ServerSideException attribute) multiprocess module multiprocess.multiproc_distributor module multiprocess.multiproc_queue module MultiprocessDistributor (class in multiprocess.multiproc_distributor) MultiprocessQueue (class in multiprocess.multiproc_queue) MultiprocessWorkerNode (class in multiprocess.multiproc_distributor)

N

name (client.array.Array property) (client.task.Task attribute) (client.tool.Tool attribute) (client.workflow.Workflow attribute) (core.config.structlog_config._NamedPrintLogger attribute) (core.task_generator.TaskGenerator attribute) (server.web.models.arg.Arg attribute) (server.web.models.arg_type.ArgType attribute) (server.web.models.array.Array attribute) (server.web.models.cluster.Cluster attribute) (server.web.models.cluster_type.ClusterType attribute) (server.web.models.queue.Queue attribute) (server.web.models.task.Task attribute) (server.web.models.task_attribute_type.TaskAttributeType attribute) (server.web.models.task_template.TaskTemplate attribute) (server.web.models.tool.Tool attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_attribute_type.WorkflowAttributeType attribute) (server.web.routes.utils.User attribute) (server.web.schemas.task.TaskDependencyItem attribute) (server.web.schemas.task_template.TaskTemplateVersionItem attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) name_func (core.task_generator.TaskGenerator attribute) NO_DISTRIBUTOR_ID (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) NO_HEARTBEAT (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) no_heartbeat_error() (distributor.distributor_service.DistributorService method) Node (class in client.node) (class in server.web.models.node)

node (client.task.Task attribute) NODE_ARG (core.constants.ArgType attribute) (server.web.models.arg_type.ArgType attribute) node_args (client.node.Node attribute) (client.task_template_version.TaskTemplateVersion property) (server.web.schemas.task_template.TaskTemplateResourceUsageRequest attribute) node_args_hash (client.node.Node attribute) (server.web.models.node.Node attribute) node_id (client.node.Node property) (server.web.models.edge.Edge attribute) (server.web.models.node_arg.NodeArg attribute) (server.web.models.task.Task attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) NodeArg (class in server.web.models.node_arg) NodeDependencyNotExistError nodename (server.web.models.task_instance.TaskInstance attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) Nodes nodes (client.dag.Dag attribute) nonce (server.web.routes.utils.User attribute) normalize_node_ids() (in module server.web.utils.json_compat) normalize_node_ids_for_client() (in module server.web.utils.json_compat) num_attempts (server.web.models.task.Task attribute) num_attempts_avg (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) num_attempts_max (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) num_attempts_min (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) num_tasks (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) num_upstreams (client.swarm.swarm_task.SwarmTask attribute) num_upstreams_done (client.swarm.swarm_task.SwarmTask attribute)

O

oauth (in module server.web.auth) oauth_instance (in module server.web.auth) oidc_router (in module server.web.routes.auth.oidc) OK (core.exceptions.ReturnCodes attribute) OP_ARG (core.constants.ArgType attribute) (server.web.models.arg_type.ArgType attribute) op_args (client.array.Array attribute) (client.task.Task attribute) (client.task_template_version.TaskTemplateVersion property) OpenTelemetryLogFormatter (in module core.otlp) option_spec (core.task_generator.TaskGeneratorDocumenter attribute) (core.task_generator.TaskGeneratorModuleDocumenter attribute)

optional_arguments (core.task_generator.TaskGeneratorDocumenter attribute) (core.task_generator.TaskGeneratorModuleDocumenter attribute) OPTIONAL_TYPES (in module core.task_generator) ORIGINAL (core.constants.TaskResourcesType attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) original_task_resources (client.task.Task property) OTLP_AVAILABLE (in module core.otlp) (in module server.web.otlp) (in module server.web.otlp.manager) otlp_flush_on_exit() (in module core.otlp.manager) OUTPUT_PATH (server.web.schemas.array.ArrayTaskInstance attribute)

P

page (server.web.schemas.task_template.ErrorLogResponse attribute) page_size (server.web.schemas.task_template.ErrorLogResponse attribute) parameters (core.cluster_protocol.ClusterQueue property) (dummy.dummy_queue.DummyQueue property) (multiprocess.multiproc_queue.MultiprocessQueue property) (sequential.seq_queue.SequentialQueue property) (server.web.models.queue.Queue attribute) params (core.task_generator.TaskGenerator attribute) parse_args() (core.cli.CLI method) parse_policy() (in module server.web.middleware.security_headers) parse_request_data() (in module server.web.routes.v3.cli.task) parser (client.cli.ClientCLI attribute) (core.cli.CLI attribute) (distributor.cli.DistributorCLI attribute) (server.cli.ServerCLI attribute) (worker_node.cli.WorkerNodeCLI attribute)

partial_reset (server.web.schemas.workflow.WorkflowResetRequest attribute) payload (server.web.server_side_exception.InvalidUsage attribute) (server.web.server_side_exception.ServerError attribute) PENDING (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) PickableTask (class in multiprocess.multiproc_distributor) plugin (core.cluster_type.ClusterType property) preferred_username (server.web.routes.utils.User attribute) prepare_task_instance_batch_for_launch() (distributor.task_instance_batch.TaskInstanceBatch method) prepend_jobmon_processors_to_existing_config() (in module core.config.structlog_config) process_commands() (client.swarm.workflow_run.WorkflowRun method) process_commands_async() (client.swarm.workflow_run.WorkflowRun method) process_group_id (server.web.models.task_instance.TaskInstance attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) process_status() (distributor.distributor_service.DistributorService method) ProcessResourceDetector (class in core.otlp.resources)

Q

Queue (class in server.web.models.queue) queue (client.task_resources.TaskResources attribute) (server.web.models.task_resources.TaskResources attribute) (server.web.schemas.task_template.QueueInfoItem attribute) (server.web.schemas.task_template.RequestedResourcesModel attribute) queue_id (core.cluster_protocol.ClusterQueue property) (dummy.dummy_queue.DummyQueue property) (multiprocess.multiproc_queue.MultiprocessQueue property) (sequential.seq_queue.SequentialQueue property) (server.web.models.task_resources.TaskResources attribute) (server.web.schemas.task_template.QueueInfoItem attribute) queue_info (server.web.schemas.task_template.MostPopularQueueResponse attribute) queue_name (client.task.Task property) (core.cluster_protocol.ClusterQueue property) (dummy.dummy_queue.DummyQueue property) (multiprocess.multiproc_queue.MultiprocessQueue property) (sequential.seq_queue.SequentialQueue property)

queue_task_batch_async() (client.swarm.workflow_run.WorkflowRun method) QUEUED (core.constants.TaskInstanceStatus attribute) (core.constants.TaskStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) QueueInfoItem (class in server.web.schemas.task_template) queues (core.cluster.Cluster attribute) (server.web.models.cluster.Cluster attribute)

R

r (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) raise_on_error (distributor.distributor_service.DistributorService attribute) readable (client.units.TimeUnit attribute) ready_to_link (server.web.models.workflow.Workflow property) ready_to_run (client.swarm.workflow_run.WorkflowRun attribute) reap() (server.web.models.workflow_run.WorkflowRun method) (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun method) reap_workflow_run() (in module server.web.routes.v3.reaper.reaper) reaper_router (in module server.web.routes.v3.reaper) ReaperWorkflowRun (class in server.workflow_reaper.reaper_workflow_run) record_array_batch_num() (in module server.web.routes.v3.fsm.array) refresh_status_from_db() (distributor.distributor_service.DistributorService method) register_otlp_shutdown_event() (in module core.otlp.manager) REGISTERED (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) REGISTERING (core.constants.TaskStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) RemoteExitInfoNotAvailable report_by_date (server.web.models.task_instance.TaskInstance attribute) request_timeout (core.requester.Requester attribute) requested_resources (client.task.Task property) (client.task_resources.TaskResources attribute) (distributor.task_instance_batch.TaskInstanceBatch property) (server.web.models.task_resources.TaskResources attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) RequestedCoresResponse (class in server.web.schemas.task_template) RequestedResourcesModel (class in server.web.schemas.task_template) Requester (class in core.requester) requester (client.array.Array attribute) (client.dag.Dag attribute) (client.node.Node attribute) (client.swarm.workflow_run.WorkflowRun attribute) (client.task.Task attribute) (client.task_resources.TaskResources attribute) (client.task_template.TaskTemplate attribute) (client.task_template_version.TaskTemplateVersion attribute) (client.tool.Tool attribute) (client.tool_version.ToolVersion attribute) (client.workflow.Workflow attribute) (client.workflow_run.WorkflowRun attribute) (client.workflow_run.WorkflowRunFactory attribute) (core.cluster.Cluster attribute) (distributor.distributor_task_instance.DistributorTaskInstance attribute) (distributor.distributor_workflow_run.DistributorWorkflowRun attribute) (distributor.task_instance_batch.TaskInstanceBatch attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance attribute) required_arguments (core.task_generator.TaskGeneratorDocumenter attribute) (core.task_generator.TaskGeneratorModuleDocumenter attribute) required_resources (core.cluster_protocol.ClusterQueue property) (dummy.dummy_queue.DummyQueue property) (multiprocess.multiproc_queue.MultiprocessQueue property) (sequential.seq_queue.SequentialQueue property)

reset() (server.web.models.task.Task method) (server.web.models.workflow.Workflow method) reset_task_statuses() (client.workflow_run.WorkflowRunFactory method) reset_workflow() (in module server.web.routes.v3.cli.workflow) (server.web.repositories.workflow_repository.WorkflowRepository method) RESOURCE_ERROR (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) resource_scales (client.array.Array property) (client.swarm.swarm_task.SwarmTask attribute) (client.task.Task property) (server.web.models.task.Task attribute) resource_usage (server.web.schemas.task.TaskResourceUsageResponse attribute) RESOURCE_USAGE (server.web.schemas.task.TaskStatusItem attribute) resource_usage() (client.task.Task method) (client.task_template.TaskTemplate method) resource_yaml() (client.cli.ClientCLI static method) ResourceDetector (class in core.otlp.resources) ResourceUsageStatistics (class in server.web.repositories.task_template_repository) response_queue (multiprocess.multiproc_distributor.Consumer attribute) (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) result_viz (server.web.schemas.task_template.TaskTemplateResourceUsageResponse attribute) resume() (server.web.models.workflow.Workflow method) resume_workflow() (client.cli.ClientCLI static method) resume_workflow_from_id() (in module client.status_commands) ResumeSet retries_attempts (core.requester.Requester attribute) retries_timeout (core.requester.Requester attribute) ReturnCodes (class in core.exceptions) run() (client.swarm.workflow_run.WorkflowRun method) (client.workflow.Workflow method) (core.task_generator.TaskGenerator method) (core.task_generator.TaskGeneratorDocumenter method) (core.task_generator.TaskGeneratorModuleDocumenter method) (distributor.distributor_service.DistributorService method) (in module worker_node.cli) (multiprocess.multiproc_distributor.Consumer method) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) run_distributor() (distributor.cli.DistributorCLI static method) run_task_generator() (worker_node.cli.WorkerNodeCLI method) run_task_instance_array() (worker_node.cli.WorkerNodeCLI method) run_task_instance_job() (worker_node.cli.WorkerNodeCLI method) RUNNING (core.constants.TaskInstanceStatus attribute) (core.constants.TaskStatus attribute) (core.constants.WorkflowRunStatus attribute) (core.constants.WorkflowStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) (server.web.models.task_status.TaskStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) (server.web.models.workflow_status.WorkflowStatus attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) runtime (server.web.schemas.task_template.RequestedResourcesModel attribute)

S

sample_error (server.web.schemas.task_template.ErrorLogItem attribute) scale_val() (client.task_resources.TaskResources static method) SCHEDULED (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) sec_to_hour() (client.units.TimeUnit static method) sec_to_min() (client.units.TimeUnit static method) seconds (client.units.TimeUnit attribute) SecurityHeadersMiddleware (class in server.web.middleware.security_headers) send() (server.workflow_reaper.notifiers.SlackNotifier method) send_request() (core.requester.Requester method) send_request_async() (core.requester.Requester method) sequential module sequential.seq_distributor module sequential.seq_queue module SequentialDistributor (class in sequential.seq_distributor) SequentialQueue (class in sequential.seq_queue) SequentialWorkerNode (class in sequential.seq_distributor) serialize() (core.task_generator.TaskGenerator method) serialize_array() (core.task_generator.TaskGenerator method) SerializeClientTaskTemplate (class in core.serializers) SerializeClientTaskTemplateVersion (class in core.serializers) SerializeClientTool (class in core.serializers) SerializeClientToolVersion (class in core.serializers) SerializeCluster (class in core.serializers) SerializeClusterType (class in core.serializers) SERIALIZED_EMPTY_STRING (in module core.task_generator) SerializeDistributorArray (class in core.serializers) SerializeDistributorTask (class in core.serializers) SerializeDistributorWorkflow (class in core.serializers) SerializeExecutorTaskInstanceErrorLog (class in core.serializers) SerializeQueue (class in core.serializers) serializers (core.task_generator.TaskGenerator attribute) SerializeSwarmTask (class in core.serializers) SerializeTaskInstance (class in core.serializers) SerializeTaskInstanceBatch (class in core.serializers) SerializeTaskInstanceErrorLog (class in core.serializers) SerializeTaskResources (class in core.serializers) SerializeTaskResourceUsage (class in core.serializers) SerializeTaskTemplateResourceUsage (class in core.serializers) SerializeWorkflowRun (class in core.serializers) server module server.cli module server.web module server.web._compat module server.web.api module server.web.auth module server.web.config module server.web.db module server.web.db.deps module server.web.db.dns module server.web.db.engine module server.web.db.migrate module server.web.error_log_clustering module server.web.hooks_and_handlers module server.web.logging module server.web.middleware module server.web.middleware.security_headers module server.web.models module server.web.models.arg module server.web.models.arg_type module server.web.models.array module server.web.models.cluster module server.web.models.cluster_type module server.web.models.dag module server.web.models.edge module server.web.models.node module server.web.models.node_arg module server.web.models.queue module server.web.models.task module server.web.models.task_arg module server.web.models.task_attribute module server.web.models.task_attribute_type module server.web.models.task_instance module server.web.models.task_instance_error_log module server.web.models.task_instance_status module server.web.models.task_resources module server.web.models.task_resources_type module server.web.models.task_status module server.web.models.task_template module server.web.models.task_template_version module server.web.models.template_arg_map module server.web.models.tool module server.web.models.tool_version module server.web.models.workflow module server.web.models.workflow_attribute module server.web.models.workflow_attribute_type module server.web.models.workflow_run module server.web.models.workflow_run_status module server.web.models.workflow_status module server.web.otlp module server.web.otlp.manager module server.web.repositories module server.web.repositories.array_repository module server.web.repositories.task_repository module server.web.repositories.task_template_repository module server.web.repositories.workflow_repository module server.web.routes module server.web.routes.auth module server.web.routes.auth.oidc module server.web.routes.auth.oidc.oidc module server.web.routes.utils module server.web.routes.v3 module server.web.routes.v3.cli module server.web.routes.v3.cli.array module server.web.routes.v3.cli.task module server.web.routes.v3.cli.task_template module server.web.routes.v3.cli.workflow module server.web.routes.v3.fsm module server.web.routes.v3.fsm.array module server.web.routes.v3.fsm.cluster module server.web.routes.v3.fsm.dag module

server.web.routes.v3.fsm.node module server.web.routes.v3.fsm.queue module server.web.routes.v3.fsm.task module server.web.routes.v3.fsm.task_instance module server.web.routes.v3.fsm.task_resources module server.web.routes.v3.fsm.task_template module server.web.routes.v3.fsm.tool module server.web.routes.v3.fsm.tool_version module server.web.routes.v3.fsm.workflow module server.web.routes.v3.fsm.workflow_run module server.web.routes.v3.reaper module server.web.routes.v3.reaper.reaper module server.web.schemas module server.web.schemas.array module server.web.schemas.task module server.web.schemas.task_template module server.web.schemas.workflow module server.web.server_side_exception module server.web.utils module server.web.utils.json_compat module server.web.utils.time_sql module server.workflow_reaper module server.workflow_reaper.api module server.workflow_reaper.notifiers module server.workflow_reaper.reaper_workflow_run module server.workflow_reaper.start module server.workflow_reaper.workflow_reaper module SERVER_STOP_STATUSES (in module client.swarm.workflow_run) server_structlog_context (core.requester.Requester attribute) ServerCLI (class in server.cli) ServerError ServerOTLPManager (class in server.web.otlp) (class in server.web.otlp.manager) ServerSideException service_url (core.requester.Requester attribute) session (server.web.repositories.array_repository.ArrayRepository attribute) (server.web.repositories.task_repository.TaskRepository attribute) (server.web.repositories.task_template_repository.TaskTemplateRepository attribute) (server.web.repositories.workflow_repository.WorkflowRepository attribute) SessionMaker (in module server.web._compat) (in module server.web.routes) set() (core.configuration.JobmonConfig method) set_active_task_template_version() (client.task_template.TaskTemplate method) set_active_task_template_version_id() (client.task_template.TaskTemplate method) set_active_tool_version_id() (client.tool.Tool method) set_command_output() (worker_node.worker_node_task_instance.WorkerNodeTaskInstance method) set_compute_resources_from_yaml() (client.task.Task method) set_default_clu() (client.tool.Tool method) set_default_cluster_name() (client.tool.Tool method) (client.workflow.Workflow method) set_default_compute_resources_from_dict() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method) (client.workflow.Workflow method) set_default_compute_resources_from_yaml() (client.task_template.TaskTemplate method) (client.tool.Tool method) (client.workflow.Workflow method) set_default_max_attempts() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method) (client.workflow.Workflow method) set_default_resource_scales_from_dict() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method) (client.workflow.Workflow method) set_default_resource_scales_from_yaml() (client.task_template.TaskTemplate method) (client.tool.Tool method) set_distributor_ids() (distributor.task_instance_batch.TaskInstanceBatch method) set_downstreams_from_db() (client.swarm.workflow_run.WorkflowRun method) set_initial_fringe() (client.swarm.workflow_run.WorkflowRun method) set_jobmon_context() (in module core.logging) (in module core.logging.context) set_max_concurrently_running() (client.workflow.Workflow method) set_resume() (in module server.web.routes.v3.fsm.workflow) set_status_for_triaging() (in module server.web.routes.v3.fsm.workflow_run) set_task_resume_state() (in module server.web.routes.v3.fsm.task) set_task_template_max_concurrency_limit() (client.workflow.Workflow method) set_tasks_from_db() (client.swarm.workflow_run.WorkflowRun method) set_workflow_metadata() (client.swarm.workflow_run.WorkflowRun method) set_workflow_resume() (client.workflow_run.WorkflowRunFactory method) set_workflow_run() (distributor.distributor_service.DistributorService method) setup() (in module core.task_generator) setup_oauth() (in module server.web.auth) shutdown() (core.otlp.manager.JobmonOTLPManager method) sid (server.web.routes.utils.User attribute) SIMPLE_TYPES (in module core.task_generator) size_limit (dummy.dummy_distributor.LimitedSizeDict attribute) (sequential.seq_distributor.LimitedSizeDict attribute) SlackNotifier (class in server.workflow_reaper.notifiers) SpecialChars (class in core.constants) start() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) start_workflow_reaper() (in module server.workflow_reaper.start) started (dummy.dummy_distributor.DummyDistributor attribute) (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) (sequential.seq_distributor.SequentialDistributor attribute) status (client.swarm.swarm_task.SwarmTask attribute) (client.swarm.workflow_run.WorkflowRun property) (client.workflow_run.WorkflowRun property) (distributor.distributor_task_instance.DistributorTaskInstance attribute) (distributor.distributor_workflow_run.DistributorWorkflowRun attribute) (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run.WorkflowRun attribute) (server.web.schemas.task.TaskDependencyItem attribute) STATUS (server.web.schemas.task.TaskStatusItem attribute) status (server.web.schemas.task.TaskStatusRequest attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) status_code (server.web.server_side_exception.InvalidUsage attribute) (server.web.server_side_exception.ServerError attribute) status_date (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run.WorkflowRun attribute) stderr (server.web.models.task_instance.TaskInstance attribute) STDERR (server.web.schemas.task.TaskStatusItem attribute) stderr (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) stderr_log (server.web.models.task_instance.TaskInstance attribute) stdout (server.web.models.task_instance.TaskInstance attribute) STDOUT (server.web.schemas.task.TaskStatusItem attribute) stdout (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) stdout_log (server.web.models.task_instance.TaskInstance attribute) stop() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) STOPPED (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) structlog_otlp_capture_enabled() (in module core.config.structlog_config) sub (server.web.routes.utils.User attribute) sub_task (server.web.schemas.task.TaskSubdagResponse attribute) submission_name (distributor.distributor_task_instance.DistributorTaskInstance property) (distributor.task_instance_batch.TaskInstanceBatch property) submit_array_to_batch_distributor() (core.cluster_protocol.ClusterDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) submit_to_batch_distributor() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) submitted_date (server.web.models.task_instance.TaskInstance attribute) SUBMITTED_TO_BATCH_DISTRIBUTOR (core.constants.TaskInstanceStatus attribute) subtract_time() (in module server.web._compat) subtract_time_expr() (in module server.web.utils) (in module server.web.utils.time_sql) swagger_bundle_shasum (in module server.web.middleware.security_headers) SwarmArray (class in client.swarm.swarm_array) SwarmCommand (class in client.swarm.workflow_run) SwarmTask (class in client.swarm.swarm_task) synchronize_state() (client.swarm.workflow_run.WorkflowRun method) synchronize_state_async() (client.swarm.workflow_run.WorkflowRun method)

T

Task (class in client.task) (class in server.web.models.task) task (server.web.models.task_instance.TaskInstance attribute) TASK_ARG (core.constants.ArgType attribute) (server.web.models.arg_type.ArgType attribute) task_args (client.array.Array attribute) (client.task.Task attribute) (client.task_template_version.TaskTemplateVersion property) task_args_hash (client.task.Task attribute) (server.web.models.task.Task attribute) task_attribute_type_id (server.web.models.task_attribute.TaskAttribute attribute) task_attributes (client.task.Task attribute) task_command (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_dependencies() (client.cli.ClientCLI static method) task_details (server.web.schemas.task.TaskDetailsResponse attribute) task_details_by_wf_id() (in module server.web.routes.v3.cli.workflow) task_errors (client.workflow.Workflow property) task_function (core.task_generator.TaskGenerator attribute) task_generator() (in module core.task_generator) task_hash (client.workflow.Workflow property) (server.web.models.workflow.Workflow attribute) task_id (client.swarm.swarm_task.SwarmTask attribute) (client.task.Task property) (server.web.models.task_arg.TaskArg attribute) (server.web.models.task_attribute.TaskAttribute attribute) (server.web.models.task_instance.TaskInstance attribute) TASK_ID (server.web.schemas.array.ArrayTaskInstance attribute) (server.web.schemas.task.TaskStatusItem attribute) task_id (server.web.schemas.task_template.ErrorLogItem attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_ids (server.web.schemas.task.DownstreamTasksRequest attribute) (server.web.schemas.task.TasksRecursiveRequest attribute) (server.web.schemas.task.TasksRecursiveResponse attribute) (server.web.schemas.task.TaskStatusRequest attribute) (server.web.schemas.task.TaskSubdagRequest attribute) (server.web.schemas.task_template.ErrorLogItem attribute) (server.web.schemas.workflow.WorkflowValidationRequest attribute) task_instance (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) task_instance_err_id (server.web.schemas.task_template.ErrorLogItem attribute) task_instance_id (distributor.distributor_task_instance.DistributorTaskInstance attribute) (server.web.models.task_instance_error_log.TaskInstanceErrorLog attribute) TASK_INSTANCE_ID (server.web.schemas.array.ArrayTaskInstance attribute) (server.web.schemas.task.TaskStatusItem attribute) task_instance_id (server.web.schemas.task_template.ErrorLogItem attribute) (worker_node.worker_node_task_instance.WorkerNodeTaskInstance property) task_instance_ids (server.web.schemas.task_template.ErrorLogItem attribute) task_instance_status (server.web.schemas.task.TaskStatusResponse attribute) task_instance_stderr_log (server.web.schemas.task_template.ErrorLogItem attribute) task_instances (distributor.task_instance_batch.TaskInstanceBatch attribute) (server.web.models.task.Task attribute) task_instances_status_check() (in module server.web.routes.v3.fsm.workflow_run) task_max_attempts (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) TASK_NAME (server.web.schemas.array.ArrayTaskInstance attribute) task_name (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_num_attempts (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_queue (multiprocess.multiproc_distributor.Consumer attribute) (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) task_resources (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) task_resources_id (distributor.task_instance_batch.TaskInstanceBatch attribute) (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) task_resources_type (server.web.models.task_resources.TaskResources attribute) task_resources_type_id (server.web.models.task_resources.TaskResources attribute) TASK_RUNNER_NAME (in module core.task_generator) TASK_RUNNER_SUB_COMMAND (in module core.task_generator) task_status (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task.TaskStatusItem attribute) (server.web.schemas.task.TaskSubdagRequest attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_status() (client.cli.ClientCLI static method) (in module client.status_commands) task_status_date (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task_template.TaskResourceDetailItem attribute) (server.web.schemas.task_template.TaskResourceVizItem attribute) (server.web.schemas.workflow.TaskTableItem attribute) task_status_updates() (in module server.web.routes.v3.fsm.workflow) task_template (client.task_template_version.TaskTemplateVersion property) (server.web.models.task_template_version.TaskTemplateVersion attribute) task_template_dag() (in module server.web.routes.v3.fsm.workflow) task_template_id (server.web.models.task_template_version.TaskTemplateVersion attribute) (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task_template.TaskTemplateDetailsResponse attribute) task_template_name (server.web.schemas.task_template.TaskTemplateDetailsResponse attribute) task_template_resources() (client.cli.ClientCLI static method) (in module client.status_commands) task_template_version (client.array.Array attribute) (client.node.Node attribute) (server.web.models.template_arg_map.TemplateArgMap attribute) task_template_version_id (client.node.Node property) (server.web.models.array.Array attribute) (server.web.models.node.Node attribute) (server.web.models.template_arg_map.TemplateArgMap attribute) (server.web.schemas.task_template.TaskTemplateDetailsResponse attribute) (server.web.schemas.task_template.TaskTemplateResourceUsageRequest attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) task_template_version_ids (server.web.schemas.task_template.TaskTemplateVersionResponse attribute) task_template_versions (client.task_template.TaskTemplate property) (server.web.models.task_template.TaskTemplate attribute) task_templates (client.tool_version.ToolVersion attribute) (server.web.models.tool_version.ToolVersion attribute) task_type (multiprocess.multiproc_distributor.PickableTask attribute) TaskArg (class in server.web.models.task_arg) TaskAttribute (class in server.web.models.task_attribute) TaskAttributeType (class in server.web.models.task_attribute_type) TaskDependenciesResponse (class in server.web.schemas.task) TaskDependencyItem (class in server.web.schemas.task) TaskDetailItem (class in server.web.schemas.task) TaskDetailsResponse (class in server.web.schemas.task) TaskGenerator (class in core.task_generator) TaskGeneratorDocumenter (class in core.task_generator) TaskGeneratorModuleDocumenter (class in core.task_generator) TaskInstance (class in server.web.models.task_instance) TaskInstanceBatch (class in distributor.task_instance_batch) TaskInstanceDetailItem (class in server.web.schemas.task) TaskInstanceDetailsResponse (class in server.web.schemas.task) TaskInstanceErrorLog (class in server.web.models.task_instance_error_log) taskinstances (server.web.schemas.task.TaskInstanceDetailsResponse attribute) TaskInstanceStatus (class in core.constants) (class in server.web.models.task_instance_status) TaskRepository (class in server.web.repositories.task_repository) TaskResourceDetailItem (class in server.web.schemas.task_template) TaskResources (class in client.task_resources) (class in server.web.models.task_resources) TaskResourcesType (class in core.constants) (class in server.web.models.task_resources_type) TaskResourceUsageResponse (class in server.web.schemas.task) TaskResourceVizItem (class in server.web.schemas.task_template) tasks (client.array.Array attribute) (client.swarm.swarm_array.SwarmArray attribute) (client.swarm.workflow_run.WorkflowRun attribute) (client.workflow.Workflow attribute) (server.web.schemas.task_template.WorkflowTaskTemplateStatusItem attribute) (server.web.schemas.workflow.TaskTableResponse attribute)

TasksRecursiveRequest (class in server.web.schemas.task) TasksRecursiveResponse (class in server.web.schemas.task) TaskStatus (class in core.constants) (class in server.web.models.task_status) TaskStatusItem (class in server.web.schemas.task) TaskStatusRequest (class in server.web.schemas.task) TaskStatusResponse (class in server.web.schemas.task) TaskSubdagRequest (class in server.web.schemas.task) TaskSubdagResponse (class in server.web.schemas.task) TaskTableItem (class in server.web.schemas.workflow) TaskTableResponse (class in server.web.schemas.workflow) TaskTemplate (class in client.task_template) (class in server.web.models.task_template) TaskTemplateDetailsResponse (class in server.web.schemas.task_template) TaskTemplateRepository (class in server.web.repositories.task_template_repository) TaskTemplateResourceUsageRequest (class in server.web.schemas.task_template) TaskTemplateResourceUsageResponse (class in server.web.schemas.task_template) TaskTemplateVersion (class in client.task_template_version) (class in server.web.models.task_template_version) TaskTemplateVersionItem (class in server.web.schemas.task_template) TaskTemplateVersionResponse (class in server.web.schemas.task_template) temp_dir (multiprocess.multiproc_distributor.MultiprocessDistributor attribute) template_arg_map (server.web.models.arg.Arg attribute) (server.web.models.arg_type.ArgType attribute) (server.web.models.task_template_version.TaskTemplateVersion attribute) template_args (client.task_template_version.TaskTemplateVersion property) template_constructor() (in module core.config.template_loader) template_name (client.task_template.TaskTemplate attribute) TemplateArgMap (class in server.web.models.template_arg_map) TemplateLoader (class in core.config.template_loader) terminable() (server.web.models.workflow_run.WorkflowRun method) terminate_db() (in module server.web.db) (in module server.web.db.migrate) (server.cli.ServerCLI method) terminate_task_instances() (core.cluster_protocol.ClusterDistributor method) (dummy.dummy_distributor.DummyDistributor method) (multiprocess.multiproc_distributor.MultiprocessDistributor method) (sequential.seq_distributor.SequentialDistributor method) terminate_workflow_run() (in module server.web.routes.v3.fsm.workflow_run) TERMINATED (core.constants.WorkflowRunStatus attribute) (server.web.models.workflow_run_status.WorkflowRunStatus attribute) TERMINATING_STATUSES (in module client.swarm.workflow_run) test_route() (in module server.web.routes) (in module server.web.routes.v3) ti_distributor_id (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_error_log_description (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_id (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_maxrss (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_nodename (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_queue_name (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_resources (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_status (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_status_date (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_stderr (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_stderr_log (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_stdout (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_stdout_log (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_submit_date (server.web.schemas.task.TaskInstanceDetailItem attribute) ti_wallclock (server.web.schemas.task.TaskInstanceDetailItem attribute) TimeUnit (class in client.units) to_dict() (server.web.server_side_exception.InvalidUsage method) (server.web.server_side_exception.ServerError method) to_user_dict() (in module server.web.routes.utils) to_wire() (core.serializers.SerializeClientTaskTemplate static method) (core.serializers.SerializeClientTaskTemplateVersion static method) (core.serializers.SerializeClientTool static method) (core.serializers.SerializeClientToolVersion static method) (core.serializers.SerializeCluster static method) (core.serializers.SerializeClusterType static method) (core.serializers.SerializeDistributorArray static method) (core.serializers.SerializeDistributorTask static method) (core.serializers.SerializeDistributorWorkflow static method) (core.serializers.SerializeExecutorTaskInstanceErrorLog static method) (core.serializers.SerializeQueue static method) (core.serializers.SerializeSwarmTask static method) (core.serializers.SerializeTaskInstanceBatch static method) (core.serializers.SerializeTaskInstanceErrorLog static method) (core.serializers.SerializeTaskResources static method) (core.serializers.SerializeTaskResourceUsage static method) (core.serializers.SerializeTaskTemplateResourceUsage static method) (core.serializers.SerializeWorkflowRun static method) (server.web.models.task_attribute.TaskAttribute method) (server.web.models.task_attribute_type.TaskAttributeType method) (server.web.models.task_instance_error_log.TaskInstanceErrorLog method) (server.web.models.workflow_attribute.WorkflowAttribute method) (server.web.models.workflow_attribute_type.WorkflowAttributeType method) to_wire_as_client_task_template() (server.web.models.task_template.TaskTemplate method) to_wire_as_client_task_template_version() (server.web.models.task_template_version.TaskTemplateVersion method) to_wire_as_client_tool() (server.web.models.tool.Tool method) to_wire_as_client_tool_version() (server.web.models.tool_version.ToolVersion method) to_wire_as_distributor_array() (server.web.models.array.Array method) to_wire_as_distributor_task() (server.web.models.task.Task method) to_wire_as_distributor_task_instance() (server.web.models.task_instance.TaskInstance method) to_wire_as_distributor_workflow() (server.web.models.workflow.Workflow method) to_wire_as_reaper_workflow_run() (server.web.models.workflow_run.WorkflowRun method) to_wire_as_requested_by_client() (server.web.models.cluster.Cluster method) (server.web.models.queue.Queue method) to_wire_as_swarm_task() (server.web.models.task.Task method) to_wire_as_task_resources() (server.web.models.task_resources.TaskResources method) to_wire_as_worker_node_task_instance() (server.web.models.task_instance.TaskInstance method) to_wire_distributor() (core.serializers.SerializeTaskInstance static method) to_wire_worker_node() (core.serializers.SerializeTaskInstance static method) Tool (class in client.tool) (class in server.web.models.tool) tool (client.tool_version.ToolVersion property) (client.workflow.Workflow property) (core.task_generator.TaskGenerator attribute) (server.web.models.tool_version.ToolVersion attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) tool_id (server.web.models.tool_version.ToolVersion attribute) tool_name (server.web.schemas.workflow.WorkflowDetailsItem attribute) tool_version (client.task_template.TaskTemplate property) tool_version_id (server.web.models.task_template.TaskTemplate attribute) (server.web.models.workflow.Workflow attribute) tool_versions (client.tool.Tool attribute) (server.web.models.task_template.TaskTemplate attribute) (server.web.models.tool.Tool attribute) ToolVersion (class in client.tool_version) (class in server.web.models.tool_version) total_count (server.web.schemas.task_template.ErrorLogResponse attribute) tracer_provider (core.otlp.manager.JobmonOTLPManager attribute) (server.web.otlp.manager.ServerOTLPManager property) (server.web.otlp.ServerOTLPManager property) tracing_span() (core.requester.Requester method) transit_ti_and_t() (in module server.web.routes.v3.fsm.task_instance) transition() (server.web.models.task.Task method) (server.web.models.task_instance.TaskInstance method) (server.web.models.workflow.Workflow method) (server.web.models.workflow_run.WorkflowRun method) transition_after_task_instance_error() (server.web.models.task.Task method) transition_array_to_launched() (in module server.web.routes.v3.fsm.array) transition_to_error() (distributor.distributor_task_instance.DistributorTaskInstance method) transition_to_instantiated() (distributor.distributor_workflow_run.DistributorWorkflowRun method) transition_to_killed() (distributor.task_instance_batch.TaskInstanceBatch method) (in module server.web.routes.v3.fsm.array) transition_to_launched() (distributor.distributor_task_instance.DistributorTaskInstance method) (distributor.distributor_workflow_run.DistributorWorkflowRun method) (distributor.task_instance_batch.TaskInstanceBatch method) transition_to_no_distributor_id() (distributor.distributor_task_instance.DistributorTaskInstance method) transition_to_resource_error() (distributor.distributor_task_instance.DistributorTaskInstance method) transition_to_unknown_error() (distributor.distributor_task_instance.DistributorTaskInstance method) TransitionError triage_error() (distributor.distributor_service.DistributorService method) TRIAGING (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) true_path() (in module core.jobmon_utils)

U

UNKNOWN_ERROR (core.constants.TaskInstanceStatus attribute) (server.web.models.task_instance_status.TaskInstanceStatus attribute) unset_jobmon_context() (in module core.logging) (in module core.logging.context) untimely_transitions (server.web.models.task_instance.TaskInstance attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run.WorkflowRun attribute) UP (core.constants.Direction attribute) up (server.web.schemas.task.TaskDependenciesResponse attribute) update_array_max_running() (in module server.web.routes.v3.fsm.workflow) update_compute_resources() (client.task.Task method) update_config() (client.cli.ClientCLI static method) update_config_value() (in module client.status_commands) update_default_compute_resources() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method) update_default_resource_scales() (client.task_template.TaskTemplate method) (client.task_template_version.TaskTemplateVersion method) (client.tool.Tool method) (client.tool_version.ToolVersion method)

update_max_running() (in module server.web.routes.v3.fsm.workflow) update_resource_scales() (client.task.Task method) update_task_status() (client.cli.ClientCLI static method) (in module client.status_commands) update_task_statuses() (in module server.web.routes.v3.cli.task) (server.web.repositories.task_repository.TaskRepository method) update_workflow_attribute() (in module server.web.routes.v3.fsm.workflow) updated_at (server.web.routes.utils.User attribute) upgrade_db() (server.cli.ServerCLI method) upstream_node_ids (server.web.models.edge.Edge attribute) upstream_nodes (client.node.Node attribute) upstream_tasks (client.array.Array attribute) (client.task.Task attribute) url (core.requester.Requester property) usage_str (server.web.models.task_instance.TaskInstance attribute) User (class in server.web.routes.utils) user (client.workflow_run.WorkflowRun attribute) (server.web.models.workflow_run.WorkflowRun attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) user_in_group() (in module server.web.routes.utils) userinfo() (in module server.web.routes.auth.oidc.oidc)

V

val (server.web.models.node_arg.NodeArg attribute) (server.web.models.task_arg.TaskArg attribute) valid_transitions (server.web.models.task.Task attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.models.workflow.Workflow attribute) (server.web.models.workflow_run.WorkflowRun attribute) validate() (client.array.Array method) (client.dag.Dag method) (client.workflow.Workflow method) validate_otlp_exporter_config() (in module core.otlp.manager) validate_resources() (client.task_resources.TaskResources method) (core.cluster_protocol.ClusterQueue method) (dummy.dummy_queue.DummyQueue method) (multiprocess.multiproc_queue.MultiprocessQueue method) (sequential.seq_queue.SequentialQueue method)

validate_task_resource_scales() (in module client.task) validate_username() (in module client.status_commands) validate_workflow() (in module client.status_commands) validate_workflow_for_update() (in module server.web.routes.v3.cli.task) VALIDATED (core.constants.TaskResourcesType attribute) (server.web.models.task_resources_type.TaskResourcesType attribute) validation (server.web.schemas.workflow.WorkflowUserValidationResponse attribute) (server.web.schemas.workflow.WorkflowValidationResponse attribute) value (server.web.models.task_attribute.TaskAttribute attribute) (server.web.models.workflow_attribute.WorkflowAttribute attribute) version (in module server.web.routes.v3) viz (server.web.schemas.task_template.TaskTemplateResourceUsageRequest attribute) viz_data (server.web.repositories.task_template_repository.ResourceUsageStatistics attribute)

W

wait_for_startup_signal() (client.workflow.DistributorContext method) wait_for_workflow_resume() (client.workflow_run.WorkflowRunFactory method) wallclock (server.web.models.task_instance.TaskInstance attribute) wedged_workflow_sync_interval (client.swarm.workflow_run.WorkflowRun attribute) wf_args (server.web.schemas.workflow.WorkflowDetailsItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) wf_attribute_key (server.web.schemas.workflow.WorkflowOverviewRequest attribute) wf_attribute_value (server.web.schemas.workflow.WorkflowOverviewRequest attribute) wf_created_date (server.web.schemas.workflow.WorkflowDetailsItem attribute) wf_details_by_wf_id() (in module server.web.routes.v3.cli.workflow) wf_id (server.web.schemas.workflow.WorkflowOverviewItem attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) wf_name (server.web.schemas.workflow.WorkflowDetailsItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) (server.web.schemas.workflow.WorkflowOverviewRequest attribute) wf_status (server.web.schemas.workflow.WorkflowDetailsItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) wf_status_date (server.web.schemas.workflow.WorkflowDetailsItem attribute) (server.web.schemas.workflow.WorkflowOverviewItem attribute) wf_status_desc (server.web.schemas.workflow.WorkflowDetailsItem attribute) wf_submitted_date (server.web.schemas.workflow.WorkflowOverviewItem attribute) wf_tool (server.web.schemas.workflow.WorkflowOverviewItem attribute) wfr_count (server.web.schemas.workflow.WorkflowOverviewItem attribute) wfr_heartbeat_date (server.web.schemas.workflow.WorkflowDetailsItem attribute) wfr_jobmon_version (server.web.schemas.workflow.WorkflowDetailsItem attribute) wfr_user (server.web.schemas.workflow.WorkflowDetailsItem attribute) worker_node module worker_node.cli module worker_node.config module worker_node.worker_node_factory module worker_node.worker_node_task_instance module WORKER_NODE_CLI_FAILURE (core.exceptions.ReturnCodes attribute) worker_node_entry_point (core.cluster_protocol.ClusterDistributor property) (dummy.dummy_distributor.DummyDistributor property) (multiprocess.multiproc_distributor.MultiprocessDistributor property) (sequential.seq_distributor.SequentialDistributor property) WORKER_NODE_ENV_FAILURE (core.exceptions.ReturnCodes attribute) WorkerNodeCLI (class in worker_node.cli) WorkerNodeFactory (class in worker_node.worker_node_factory) WorkerNodeTaskInstance (class in worker_node.worker_node_task_instance) Workflow (class in client.workflow) (class in server.web.models.workflow) workflow (client.array.Array property) (client.task.Task property) (server.web.models.dag.Dag attribute) (server.web.models.workflow_run.WorkflowRun attribute) Workflow Attributes workflow_args (server.web.models.workflow.Workflow attribute) workflow_args_hash (client.workflow.Workflow attribute) (server.web.models.workflow.Workflow attribute) workflow_attribute_type_id (server.web.models.workflow_attribute.WorkflowAttribute attribute) workflow_attributes (client.workflow.Workflow attribute) workflow_id (client.workflow.Workflow property) (client.workflow_run.WorkflowRun attribute) (client.workflow_run.WorkflowRunFactory attribute) (server.web.models.array.Array attribute) (server.web.models.task.Task attribute) (server.web.models.workflow_attribute.WorkflowAttribute attribute) (server.web.models.workflow_run.WorkflowRun attribute) (server.web.schemas.task.TaskDetailItem attribute) (server.web.schemas.task.TaskSubdagResponse attribute) (server.web.schemas.task_template.ErrorLogItem attribute) (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun attribute)

workflow_is_resumable (client.workflow_run.WorkflowRunFactory attribute) workflow_is_resumable() (in module server.web.routes.v3.fsm.workflow) workflow_reaper() (server.cli.ServerCLI method) workflow_reset() (client.cli.ClientCLI static method) (in module client.status_commands) workflow_run_id (client.swarm.workflow_run.WorkflowRun attribute) (client.workflow_run.WorkflowRun property) (distributor.distributor_task_instance.DistributorTaskInstance attribute) (distributor.distributor_workflow_run.DistributorWorkflowRun attribute) (server.web.models.task_instance.TaskInstance attribute) (server.web.schemas.task_template.ErrorLogItem attribute) (server.web.schemas.workflow.WorkflowRunForResetResponse attribute) (server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun attribute) workflow_runs (server.web.models.workflow.Workflow attribute) workflow_status (server.web.schemas.workflow.WorkflowValidationResponse attribute) workflow_status() (client.cli.ClientCLI static method) (in module client.status_commands) workflow_tasks (server.web.schemas.workflow.WorkflowTasksResponse attribute) workflow_tasks() (client.cli.ClientCLI static method) (in module client.status_commands) WorkflowAlreadyComplete WorkflowAlreadyExists WorkflowArgs WorkflowAttribute (class in server.web.models.workflow_attribute) WorkflowAttributeType (class in server.web.models.workflow_attribute_type) WorkflowDetailsItem (class in server.web.schemas.workflow) WorkflowDetailsResponse (class in server.web.schemas.workflow) WorkflowNotResumable WorkflowOverviewItem (class in server.web.schemas.workflow) WorkflowOverviewRequest (class in server.web.schemas.workflow) WorkflowOverviewResponse (class in server.web.schemas.workflow) WorkflowReaper (class in server.workflow_reaper.workflow_reaper) WorkflowRepository (class in server.web.repositories.workflow_repository) WorkflowResetRequest (class in server.web.schemas.workflow) WorkflowRun (class in client.swarm.workflow_run) (class in client.workflow_run) (class in server.web.models.workflow_run) WorkflowRunFactory (class in client.workflow_run) WorkflowRunForResetResponse (class in server.web.schemas.workflow) WorkflowRunStateError WorkflowRunStatus (class in core.constants) (class in server.web.models.workflow_run_status) workflows (server.web.schemas.task_template.TaskTemplateResourceUsageRequest attribute) (server.web.schemas.workflow.WorkflowOverviewResponse attribute) (server.web.schemas.workflow.WorkflowStatusResponse attribute) workflows_by_user_form() (in module server.web.routes.v3.cli.workflow) WorkflowStatus (class in core.constants) (class in server.web.models.workflow_status) WorkflowStatusResponse (class in server.web.schemas.workflow) WorkflowStatusVizResponse (class in server.web.schemas.workflow) WorkflowTasksResponse (class in server.web.schemas.workflow) WorkflowTaskTemplateStatusItem (class in server.web.schemas.task_template) WorkflowTestError WorkflowUserValidationResponse (class in server.web.schemas.workflow) WorkflowValidationRequest (class in server.web.schemas.workflow) WorkflowValidationResponse (class in server.web.schemas.workflow) write() (core.configuration.JobmonConfig method)