Index

A

abog (firexkit.task.FireXTask property) accept_content (firexapp.engine.default_celery_config.FxCeleryConfig attribute) actual_runtime (firex_keeper.keeper_helper.FireXTreeTask attribute) add_entry() (firexapp.submit.reporting.ReportGenerator method) add_filter_to_console() (in module firexapp.submit.console) add_task_logfile_handler() (firexkit.task.FireXTask method) add_task_result_with_report_to_db() (firexkit.task.FireXTask method) (in module firexkit.task) add_viewers() (firexapp.submit.uid.Uid method) AdjustCeleryConcurrency (class in firexapp.submit.submit) all_args (firexkit.task.FireXTask property) all_supplied_args() (firexkit.bag_of_goodies.BagOfGoodies method) apply_async() (firexkit.task.FireXTask method) apply_async_x() (firexkit.chain.SignatureX method) arg_name (firexkit.bag_of_goodies.AutoInjectSpec attribute) arg_type (firexkit.bag_of_goodies.AutoInjectSpec attribute)

args (firexkit.bag_of_goodies.BagOfGoodies property) (firexkit.task.FireXTask property) ArgumentConversionException as_dict() (firexkit.result.ManyFxAsyncResults method) as_host_worker() (firexkit.task.FxWorkerName method) assert_expected_firex_output() (firexapp.testing.config_base.FlowTestConfiguration method) assert_expected_return_code() (firexapp.testing.config_base.FlowTestConfiguration method) assert_is_bad_run() (in module firexapp.testing.config_base) assert_is_good_run() (in module firexapp.testing.config_base) AsyncResult() (firexkit.task.FireXTask method) ATTEMPT (firexkit.bag_of_goodies.ValidateArgs attribute) AUTO_IN_REG_ABOG_KEY (firexkit.bag_of_goodies.AutoInjectRegistry attribute) auto_inject_reg() (firexkit.task.TaskContext method) auto_load_pydev_debugging_plugin() (in module firexapp.submit.arguments) AutoInject (firexkit.task.FireXTask attribute) AutoInjectRegistry (class in firexkit.bag_of_goodies) AutoInjectSpec (class in firexkit.bag_of_goodies)

B

BagOfGoodies (class in firexkit.bag_of_goodies) banner() (in module firexkit.task) base_logging_dir (firexapp.submit.uid.Uid property) BlazeKafkaSenderThread (class in firex_blaze.blaze_event_consumer) BlazeSenderConfig (class in firex_blaze.blaze_helper) Block (firexkit.task.PendingChildStrategy attribute) bog (firexkit.task.TaskContext attribute)

bound_args (firexkit.task.FireXTask property) broker (firexapp.engine.default_celery_config.FxCeleryConfig property) BROKER (firexapp.engine.default_celery_config.FxEnvVars attribute) broker_connection_retry_on_startup (firexapp.engine.default_celery_config.FxCeleryConfig attribute) broker_url (firexapp.engine.default_celery_config.FxCeleryConfig property) (firexapp.engine.default_celery_config.FxEnvVars property) BrokerEventConsumerThread (class in firex_flame.event_broker_processor)

C

cache_call() (firexkit.task.FireXTask method) CacheResultNotPopulatedYetInRedis called_as_orig (firexkit.task.FireXTask property) cap_cpu_count() (firexapp.celery_manager.CeleryManager static method) celery_pids_dir (firexapp.celery_manager.CeleryManager property) CeleryManager (class in firexapp.celery_manager) CeleryWorkerStartFailed chain_depth (firex_keeper.keeper_helper.FireXTreeTask attribute) ChainArgException ChainException ChainInterruptedByZombieTaskException ChainInterruptedException ChainInterruptedExceptionFilter (class in firexapp.submit.console) ChainRevokedException ChainRevokedPreRunException check_for_failures() (firexapp.submit.submit.SubmitBaseApp method) children (firex_keeper.keeper_helper.FireXTreeTask attribute) CircularDependencyException cleanup() (firexapp.testing.config_base.FlowTestConfiguration method) cleanup_after_timeout() (firexapp.testing.config_interpreter.ConfigInterpreter method) clear_os_fx_env() (firexapp.engine.default_celery_config.FxEnvVars class method) clone() (firexkit.chain.InjectArgs method) (firexkit.chain.SignatureX method) collect_plugins() (firexapp.testing.config_interpreter.ConfigInterpreter method) CommaDelimitedListAction (class in firexapp.plugins) completed_run (firexapp.testing.config_base.FlowTestConfiguration property) config_interpreter (firexapp.testing.test_infra.FlowTestInfra attribute) ConfigInterpreter (class in firexapp.testing.config_interpreter) Continue (firexkit.task.PendingChildStrategy attribute) convert() (firexapp.submit.arguments.InputConverter class method) (firexkit.argument_conversion.ConverterRegister method)

convert_booleans() (in module firexapp.submit.arguments) convert_chain_args() (firexapp.submit.submit.SubmitBaseApp method) convert_plugins_to_list() (in module firexapp.plugins) convert_result_tuple_to_dict() (firexkit.result.FireXResults class method) convert_to_serializable() (in module firexkit.task) ConverterRegister (class in firexkit.argument_conversion) ConverterRegistrationException copy_resources() (firexapp.submit.uid.Uid method) copy_submission_log() (firexapp.submit.submit.SubmitBaseApp method) create_arg_parser() (firexapp.application.FireXBaseApp method) create_auto_in_reg() (firexkit.bag_of_goodies.AutoInjectRegistry static method) create_chain_sentinel_files() (firexapp.submit.submit.SubmitBaseApp method) create_cmd() (firexapp.testing.config_interpreter.ConfigInterpreter method) create_collapse_ops() (in module firexkit.task) create_debug_dir() (firexapp.submit.uid.Uid method) create_flame_config() (in module firexkit.task) create_from_abog() (firexkit.task.PauseTasks static method) create_fx_ars() (firexkit.result.ManyFxAsyncResults class method) create_info_sub_parser() (firexapp.info.InfoBaseApp method) create_link() (in module firexapp.common) create_link_async() (in module firexapp.common) create_list_sub_parser() (firexapp.info.InfoBaseApp method) create_logs_dir() (firexapp.submit.uid.Uid method) create_logs_link() (firexapp.submit.submit.SubmitBaseApp method) create_no_task_exec_fx_env() (firexapp.engine.default_celery_config.FxEnvVars class method) create_replacement_task() (firexapp.plugins.FxPluginRegistry method) create_submit_parser() (firexapp.submit.submit.SubmitBaseApp method) create_unsuccessful_result() (in module firexkit.result) create_version_sub_parser() (firexapp.info.InfoBaseApp method) CURRENT_RUN_FIREX_ID (firexapp.engine.default_celery_config.FxEnvVars attribute)

D

debug_dir (firexapp.submit.uid.Uid property) debug_dirname (firexapp.submit.uid.Uid attribute) default_bound_args (firexkit.task.FireXTask property) default_main() (in module firexapp.testing.test_infra) DEFAULT_MICROSERVICE (firexapp.submit.submit.SubmitBaseApp attribute) default_use_cache (firexkit.task.FireXTask property) default_value (firexkit.bag_of_goodies.AutoInjectSpec attribute) del_parser_attributes() (firexapp.submit.submit.SubmitBaseApp method) delay() (firexkit.chain.SignatureX method) delimit2list() (in module firexapp.common) destroy() (firexapp.fileregistry.FileRegistry class method)

dict2str() (in module firexapp.common) disable_all_ar_backends() (firexkit.result.FxAsyncResult class method) DISABLED (firexkit.bag_of_goodies.ValidateArgs attribute) discover_package_modules() (in module firexapp.discovery) discover_tests() (in module firexapp.testing.config_base) DistlibWarningsFilter (class in firexapp.submit.console) document_viewer() (firexapp.testing.config_interpreter.ConfigInterpreter method) dump_environ() (firexapp.submit.submit.SubmitBaseApp method) dump_to_file() (firexapp.fileregistry.FileRegistry method) duration() (firexkit.task.FireXTask method) DYNAMIC_RETURN (firexkit.task.FireXTask attribute)

E

employee_names_to_list() (in module firexapp.tasks.example) EMPTY (firexkit.bag_of_goodies.AutoInjectRegistry attribute) empty_auto_inject_reg() (firexkit.bag_of_goodies.AutoInjectRegistry class method) enable_ar_tracking() (firexkit.result.FxAsyncResult class method) enqueue() (firexkit.chain.SignatureX method) enqueue_and_extract() (firexkit.chain.SignatureX method) enqueue_child() (firexkit.task.FireXTask method) enqueue_child_and_extract() (firexkit.task.FireXTask method) enqueue_child_and_get_results() (firexkit.task.FireXTask method) enqueue_child_from_spec() (firexkit.task.FireXTask method)

enqueue_in_parallel() (firexkit.task.FireXTask method) enqueue_many() (firexkit.task.FireXTask method) enqueue_opts (firexkit.task.TaskEnqueueSpec attribute) enqueued_children (firexkit.task.TaskContext attribute) error_banner() (firexapp.submit.submit.SubmitBaseApp static method) exception (firex_keeper.keeper_helper.FireXTreeTask attribute) exception_cause_uuid (firex_keeper.keeper_helper.FireXTreeTask attribute) execution_directory (firexapp.testing.config_interpreter.ConfigInterpreter attribute) ExitSignalHandler (class in firexapp.application) expand_self_op() (in module firexkit.task) extra_cli_arguments() (firexapp.submit.tracking_service.TrackingService method)

F

failures (firexapp.testing.test_infra.FlowTestInfra attribute) file_logging_dirpath (firexkit.task.FireXTask property) FileRegistry (class in firexapp.fileregistry) filter() (firexapp.submit.console.ChainInterruptedExceptionFilter method) (firexapp.submit.console.DistlibWarningsFilter method) (firexapp.submit.console.RequeueingUndeliverableFilter method) (firexapp.submit.console.RetryFilter method) filter_formatters() (firexapp.submit.reporting.ReportGenerator method) filter_loaders() (firexapp.submit.reporting.ReportGenerator method) final_call() (firexkit.task.FireXTask method) find() (in module firexapp.common) find_all_firex_ids_from_str() (in module firexapp.submit.uid) find_all_procs() (firexapp.celery_manager.CeleryManager method) find_firex_task_bundles() (in module firexapp.discovery) find_in_stack() (in module firexapp.testing.coverage_plugin) find_plugin_file() (firexapp.plugins.FxPluginRegistry class method) find_single_firex_id_from_str() (in module firexapp.submit.uid) find_unsuccessful_in_chain() (in module firexkit.result) find_unused_arguments() (in module firexapp.submit.arguments) firex_blaze.blaze_event_consumer module firex_blaze.blaze_helper module firex_blaze.blaze_launcher module firex_blaze.fast_blaze_helper module firex_bound_args (firex_keeper.keeper_helper.FireXTreeTask attribute) firex_bundle_ci.tasks module firex_default_bound_args (firex_keeper.keeper_helper.FireXTreeTask attribute) firex_flame.api module firex_flame.controller module firex_flame.event_broker_processor module firex_flame.event_file_processor module firex_flame.flame_helper module firex_flame.flame_task_graph module firex_flame.launcher module firex_flame.main_app module firex_flame.model_dumper module firex_flame.web_app module firex_id (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexapp.engine.default_celery_config.FxEnvVars property) firex_id() (firexapp.submit.uid.FireXIdParts method) firex_id_str() (in module firexapp.submit.uid) firex_keeper.db_model module firex_keeper.keeper_event_consumer module firex_keeper.keeper_helper module firex_keeper.keeper_launcher module firex_keeper.persist module firex_keeper.task_query module firex_load() (firexkit.bag_of_goodies.FireXBaseBaseModel class method) firex_logs_dir (firexapp.engine.default_celery_config.FxEnvVars attribute) firex_plugins (firexapp.engine.default_celery_config.FxEnvVars attribute) firex_result (firex_keeper.keeper_helper.FireXTreeTask attribute) firex_serializable() (firexkit.result.FxAsyncResult method) firexapp.application module firexapp.celery_manager module firexapp.common module firexapp.discovery module firexapp.engine.celery module firexapp.engine.default_celery_config module firexapp.fileregistry module firexapp.info module firexapp.plugins module firexapp.submit.arguments module firexapp.submit.console module firexapp.submit.report_trigger module firexapp.submit.reporting module firexapp.submit.submit module

firexapp.submit.tracking_service module firexapp.submit.uid module firexapp.tasks.core_tasks module firexapp.tasks.example module firexapp.testing.config_base module firexapp.testing.config_interpreter module firexapp.testing.coverage_plugin module firexapp.testing.test_infra module FireXBaseApp (class in firexapp.application) FireXBaseBaseModel (class in firexkit.bag_of_goodies) FireXBlazeLauncher (class in firex_blaze.blaze_launcher) FireXColoredConsoleFormatter (class in firexapp.submit.console) FireXIdParts (class in firexapp.submit.uid) FireXKeeperLauncher (class in firex_keeper.keeper_launcher) firexkit.argument_conversion module firexkit.bag_of_goodies module firexkit.chain module firexkit.result module firexkit.revoke module firexkit.task module FireXResults (class in firexkit.result) FireXReturnCodeException FireXRunDbManager (class in firex_keeper.persist) FireXTask (class in firexkit.task) FireXTaskQueryException FireXTreeTask (class in firex_keeper.keeper_helper) FireXWaitQueryExceeded first_non_chain_interrupted_exception() (in module firexkit.result) first_started (firex_keeper.keeper_helper.FireXTreeTask attribute) first_warning (firexapp.application.ExitSignalHandler attribute) flame() (in module firexkit.task) flame_collapse() (in module firexkit.task) flame_collapse_formatter() (in module firexkit.task) flame_configs (firexkit.task.TaskContext attribute) FlameEventAggregator (class in firex_flame.flame_task_graph) FlameLauncher (class in firex_flame.launcher) FlameResponse (class in firex_flame.web_app) FlameServerConfig (class in firex_flame.flame_helper) FlowTestConfiguration (class in firexapp.testing.config_base) FlowTestInfra (class in firexapp.testing.test_infra) forget() (firexkit.result.FxEagerResult method) forget_chain_results() (in module firexkit.result) forget_specific_children_results() (firexkit.task.FireXTask method) format() (firexapp.submit.console.FireXColoredConsoleFormatter method) format_results_str() (firexapp.submit.submit.SubmitBaseApp method) formatters (firexapp.submit.reporting.ReportGenerator attribute) frequency (firexkit.result.WaitLoopCallBack attribute) from_plugin (firex_keeper.keeper_helper.FireXTreeTask attribute) from_str() (firexapp.submit.uid.FireXIdParts static method) func (firexkit.result.WaitLoopCallBack attribute) fx_ars_from_dict() (firexkit.result.ManyFxAsyncResults class method) fx_ars_from_list() (firexkit.result.ManyFxAsyncResults class method) fx_ars_from_single() (firexkit.result.ManyFxAsyncResults class method) fx_backend_get_name() (firexkit.result.FxAsyncResult method) fx_env (firexapp.engine.default_celery_config.FxCeleryConfig attribute) fx_exception_result() (firexkit.result.FxAsyncResult method) fx_forget() (firexkit.result.FxAsyncResult method) fx_get_hostname() (firexkit.result.FxAsyncResult method) fx_get_name() (firexkit.result.FxAsyncResult method) fx_get_parent() (firexkit.result.FxAsyncResult method) fx_get_parent_id() (firexkit.result.FxAsyncResult method) fx_get_queue() (firexkit.result.FxAsyncResult method) fx_get_state() (firexkit.result.FxAsyncResult method) fx_get_success_result() (firexkit.result.FxAsyncResult method) fx_is_failed() (firexkit.result.FxAsyncResult method) fx_is_forgotten() (firexkit.result.FxAsyncResult method) fx_is_ready() (firexkit.result.FxAsyncResult method) fx_is_revoked() (firexkit.result.FxAsyncResult method) fx_is_running() (firexkit.result.FxAsyncResult method) fx_is_successful() (firexkit.result.FxAsyncResult method) fx_logging_name() (firexkit.result.FxAsyncResult method) fx_seen_queue() (firexkit.result.FxAsyncResult method) fx_wait() (firexkit.result.FxAsyncResult method) fx_wait_no_state_update() (firexkit.result.FxAsyncResult method) fx_worker_name_from_queue_and_sg() (firexkit.task.FxWorkerName class method) fx_worker_name_from_str() (firexkit.task.FxWorkerName class method) fx_worker_type_from_str() (firexkit.task.FxWorkerTypes class method) FxAsyncResult (class in firexkit.result) FxCeleryConfig (class in firexapp.engine.default_celery_config) FxEagerResult (class in firexkit.result) FxEnvVars (class in firexapp.engine.default_celery_config) FxPluginRegistry (class in firexapp.plugins) FxWorkerHostName (class in firexkit.task) FxWorkerId (class in firexkit.task) FxWorkerName (class in firexkit.task) FxWorkerTypes (class in firexkit.task)

G

generate_incomplete_events() (firex_flame.flame_task_graph.FlameEventAggregator method) get() (firexkit.bag_of_goodies.AutoInjectRegistry method) get_accepted_supplied_and_default_args() (firexkit.bag_of_goodies.BagOfGoodies method) get_active_plugins() (in module firexapp.plugins) get_all_pkg_versions() (in module firexapp.discovery) get_all_pkg_versions_str() (in module firexapp.discovery) get_and_remove_chain_depth() (firexkit.bag_of_goodies.BagOfGoodies method) get_args_from_json() (in module firexapp.application) get_args_from_json_from_all_args() (in module firexapp.application) get_args_to_indirect_value_keys() (firexkit.bag_of_goodies.BagOfGoodies method) get_argument_use() (in module firexapp.info) get_as_completed() (firexkit.result.ManyFxAsyncResults method) get_attempt() (firexkit.task.FireXTask method) get_attr_unwrapped() (in module firexkit.task) get_auto_inject_registry() (firexkit.bag_of_goodies.AutoInjectRegistry class method) (firexkit.bag_of_goodies.BagOfGoodies method) get_auto_inject_type() (firexkit.bag_of_goodies.BagOfGoodies static method) get_auto_inject_values() (firexkit.bag_of_goodies.AutoInjectRegistry method) get_auto_injectable_arg_names() (firexkit.bag_of_goodies.AutoInjectRegistry method) get_available_port() (in module firexapp.common) get_cache_enabled_uid_dbkey() (in module firexkit.task) get_celery_pid() (firexapp.celery_manager.CeleryManager class method) get_chain_ancestors() (firexkit.result.FxAsyncResult method) get_chain_ancestors_as_many() (firexkit.result.FxAsyncResult method) get_chain_args() (in module firexapp.submit.arguments) get_chain_head() (firexkit.result.FxAsyncResult method) get_cli_opts() (firexkit.task.PauseTasks static method) get_current_cache_enabled_uid_dbkeys() (in module firexkit.task) get_current_cache_enabled_uids() (in module firexkit.task) get_current_enqueue_child_once_uid_dbkeys() (in module firexkit.task) get_current_enqueue_child_once_uids() (in module firexkit.task) get_current_reports_uids() (in module firexkit.task) get_db_manager() (in module firex_keeper.persist) get_enqueue_child_once_count_dbkey() (in module firexkit.task) get_enqueue_child_once_uid_dbkey() (in module firexkit.task) get_exe() (firexapp.testing.config_interpreter.ConfigInterpreter method) get_extra_run_env() (firexapp.testing.config_base.FlowTestConfiguration static method) get_file() (firexapp.fileregistry.FileRegistry method) get_firex_dependant_package_versions() (in module firexapp.discovery) get_firex_id_from_output() (in module firexapp.submit.submit) get_firex_id_parts() (in module firexapp.submit.uid) get_firex_tracking_services_entry_points() (in module firexapp.discovery) get_first_sig() (firexkit.chain.SignatureX method) get_generators() (firexapp.submit.reporting.ReportersRegistry class method) get_global_args_allowlist() (in module firexapp.submit.arguments)

get_kafka_producer() (firex_blaze.blaze_event_consumer.KafkaSenderThread class method) get_label() (firexkit.chain.SignatureX method) get_log_dir_from_output() (in module firexapp.submit.submit) get_many_results() (firexkit.result.FxAsyncResult method) get_module_file_location() (firexkit.task.FireXTask method) get_optional_args_to_default_values() (firexkit.bag_of_goodies.BagOfGoodies method) get_overridden_task() (firexkit.task.FireXTask method) get_pause_arg_names() (firexkit.task.PauseTasks static method) get_pkg_version_info() (firexapp.submit.tracking_service.TrackingService method) get_plugin_files() (firexapp.engine.default_celery_config.FxEnvVars method) get_post_pydantic_convert_supplied_arg_names() (firexkit.bag_of_goodies.BagOfGoodies method) get_public_supplied_args() (firexkit.bag_of_goodies.BagOfGoodies method) get_pydantic_convertible_arg_names() (firexkit.bag_of_goodies.BagOfGoodies method) (firexkit.task.FireXTask method) get_pydantic_validate() (firexkit.task.FireXTask method) get_redis_hostname() (firexapp.engine.default_celery_config.FxEnvVars method) get_register() (firexkit.argument_conversion.ConverterRegister class method) get_relative_path() (firexapp.fileregistry.FileRegistry method) get_request_queue() (firexkit.task.FireXTask method) get_required_arg_names() (firexkit.bag_of_goodies.BagOfGoodies method) get_resources_path() (firexapp.submit.uid.Uid class method) get_result_key() (firexkit.result.FxAsyncResult method) get_results() (in module firexkit.result) get_results_with_default() (in module firexkit.result) get_revoked_uuids() (firexkit.revoke.RevokedRequests method) get_service_name() (in module firexapp.submit.tracking_service) get_short_name() (firexkit.task.FireXTask static method) get_short_name_without_orig() (firexkit.task.FireXTask class method) get_subworker_name() (firexkit.task.FxWorkerName method) (firexkit.task.FxWorkerTypes class method) get_task_logfile() (firexkit.task.FireXTask class method) get_task_logfile_from_request() (firexkit.task.FireXTask method) get_task_logfilename() (firexkit.task.FireXTask static method) get_task_logging_dirpath_from_request() (firexkit.task.FireXTask method) get_test_name() (firexapp.testing.config_interpreter.ConfigInterpreter static method) get_tracking_services() (in module firexapp.submit.tracking_service) get_tracking_services_versions() (in module firexapp.submit.tracking_service) get_unbound_required_arg_names() (firexkit.bag_of_goodies.BagOfGoodies method) get_unsuccessful_items() (in module firexapp.submit.submit) get_unsupplied_arg_params() (firexkit.bag_of_goodies.BagOfGoodies method) get_unsupplied_default_args() (firexkit.bag_of_goodies.BagOfGoodies method) get_visit_order() (firexkit.argument_conversion.ConverterRegister method) get_worker_logs_dir() (firexapp.celery_manager.CeleryManager static method) get_worker_queue() (firexkit.task.FireXTask method) graceful_exit_on_failure() (firexapp.submit.submit.SubmitBaseApp method)

H

handle_exception() (firexkit.task.FireXTask method) has_auto_reg() (firexkit.bag_of_goodies.BagOfGoodies method) has_dynamic_returns() (firexkit.task.FireXTask method)

has_flame() (in module firexapp.submit.tracking_service) has_report_meta() (firexkit.task.FireXTask method) host (firexkit.task.FxWorkerHostName attribute) hostname (firex_keeper.keeper_helper.FireXTreeTask attribute)

I

ignore_result (firexkit.task.FireXTask attribute) IllegalTaskNameException import_plugin_file() (firexapp.plugins.FxPluginRegistry class method) import_test_configs() (in module firexapp.testing.config_base) imports (firexapp.engine.default_celery_config.FxCeleryConfig property) INDIRECT_ARG_CHAR (firexkit.bag_of_goodies.BagOfGoodies attribute) InfoBaseApp (class in firexapp.info) infra_return_keys() (firexkit.bag_of_goodies.BagOfGoodies class method) init_auto_inject_registry() (firexkit.bag_of_goodies.BagOfGoodies method) (firexkit.task.FireXTask method) init_file_logging() (firexapp.submit.submit.SubmitBaseApp method) initial_firex_options() (firexapp.testing.config_base.FlowTestConfiguration method) initialize_context() (firexkit.task.FireXTask method) inject_abog (firexkit.task.TaskEnqueueSpec attribute) InjectArgs (class in firexkit.chain) injectArgs() (firexkit.chain.SignatureX method) InputConverter (class in firexapp.submit.arguments)

install_configs (firexapp.submit.tracking_service.TrackingService attribute) instance() (firexapp.submit.arguments.InputConverter class method) InvalidChainArgsException is_cache_enabled() (firexkit.task.FireXTask method) is_celery() (in module firexapp.testing.coverage_plugin) is_current_env_fx_celery_worker() (firexapp.celery_manager.CeleryManager class method) is_dynamic_return() (firexkit.task.FireXTask class method) is_firex_id() (in module firexapp.submit.uid) is_jsonable() (in module firexkit.task) is_mc_queue() (firexkit.task.FireXTask static method) is_multi_chain() (firexkit.chain.SignatureX method) is_overriding_task() (firexkit.task.FireXTask method) is_prev_task_result() (firexkit.result.FireXResults static method) is_revoked() (firexkit.revoke.RevokedRequests method) is_revoked_uuid() (firexkit.revoke.RevokedRequests class method) is_running_under_coverage() (in module firexapp.testing.coverage_plugin) is_self_indirect_ref() (firexkit.bag_of_goodies.BagOfGoodies class method) is_submit_command() (firexapp.testing.config_interpreter.ConfigInterpreter static method)

J

JsonContentNotList

JsonFileAction (class in firexapp.submit.submit)

K

KafkaSenderThread (class in firex_blaze.blaze_event_consumer) KeeperEventAggregator (class in firex_keeper.keeper_event_consumer) KeeperQueueEntryType (class in firex_keeper.keeper_event_consumer) KeeperThreadedEventWriter (class in firex_keeper.keeper_event_consumer)

KeyAlreadyRegistered KeyNotRegistered kill_all_forked() (firexapp.celery_manager.CeleryManager method) kwargs (firexkit.result.WaitLoopCallBack attribute) (firexkit.task.FireXTask property)

L

last_causing_chain_interrupted_exception() (in module firexkit.result) last_warning (firexapp.application.ExitSignalHandler attribute) legacy_extract_results() (firexkit.result.FxAsyncResult method) link_for_logo (firexapp.engine.default_celery_config.FxCeleryConfig attribute) list_converters() (firexkit.argument_conversion.ConverterRegister class method) load_data() (firexapp.submit.reporting.ReportGenerator method) load_firex_env_vars_from_env() (firexapp.engine.default_celery_config.FxEnvVars class method) load_firex_env_vars_from_logs_dir() (firexapp.engine.default_celery_config.FxEnvVars class method) load_install_config() (firexapp.engine.default_celery_config.FxCeleryConfig method) load_plugin_modules() (firexapp.plugins.FxPluginRegistry method) loaded_firex_core_entry_points() (in module firexapp.discovery) loaded_firex_entry_points() (in module firexapp.discovery)

loaders (firexapp.submit.reporting.ReportGenerator attribute) log() (firexapp.celery_manager.CeleryManager class method) log_firex_pkgs_versions() (firexapp.submit.submit.SubmitBaseApp static method) log_preamble() (firexapp.submit.submit.SubmitBaseApp method) log_results() (firexapp.submit.submit.SubmitBaseApp static method) logs_dir (firexapp.engine.default_celery_config.FxCeleryConfig property) (firexapp.engine.default_celery_config.FxEnvVars property) (firexapp.submit.uid.Uid property) logs_dir_for_worker (firexkit.task.FireXTask property) logs_url (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexapp.engine.default_celery_config.FxCeleryConfig attribute) (firexapp.submit.uid.Uid property) long_name (firex_keeper.keeper_helper.FireXTreeTask attribute)

M

main() (in module firexapp.application) (in module firexapp.testing.test_infra) main_error_exit_handler() (firexapp.application.FireXBaseApp method) (firexapp.submit.submit.SubmitBaseApp method) ManyFxAsyncResults (class in firexkit.result) map_args() (firexkit.task.FireXTask method) MASTER (firexkit.task.FxWorkerTypes attribute) max_acceptable_failures (firexapp.testing.test_infra.FlowTestInfra attribute) mc (firexapp.engine.default_celery_config.FxCeleryConfig property) MC (firexkit.task.FxWorkerTypes attribute) merge_plugins() (in module firexapp.plugins) MESSAGE (firexkit.result.ChainInterruptedException attribute) (firexkit.result.ChainRevokedException attribute) (firexkit.result.MultipleFailuresException attribute) message_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) MissingConverterDependencyError model_config (firexapp.engine.default_celery_config.FxEnvVars attribute) (firexkit.bag_of_goodies.FireXBaseBaseModel attribute) module firex_blaze.blaze_event_consumer firex_blaze.blaze_helper firex_blaze.blaze_launcher firex_blaze.fast_blaze_helper firex_bundle_ci.tasks firex_flame.api firex_flame.controller firex_flame.event_broker_processor firex_flame.event_file_processor firex_flame.flame_helper firex_flame.flame_task_graph firex_flame.launcher firex_flame.main_app firex_flame.model_dumper firex_flame.web_app firex_keeper.db_model firex_keeper.keeper_event_consumer firex_keeper.keeper_helper firex_keeper.keeper_launcher firex_keeper.persist firex_keeper.task_query firexapp.application firexapp.celery_manager firexapp.common firexapp.discovery firexapp.engine.celery firexapp.engine.default_celery_config firexapp.fileregistry firexapp.info firexapp.plugins firexapp.submit.arguments firexapp.submit.console firexapp.submit.report_trigger firexapp.submit.reporting firexapp.submit.submit firexapp.submit.tracking_service firexapp.submit.uid firexapp.tasks.core_tasks firexapp.tasks.example firexapp.testing.config_base firexapp.testing.config_interpreter firexapp.testing.coverage_plugin firexapp.testing.test_infra firexkit.argument_conversion firexkit.bag_of_goodies firexkit.chain firexkit.result firexkit.revoke firexkit.task

MultipleFailuresException

N

name (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexapp.testing.config_base.FlowTestConfiguration property) (firexkit.task.TaskAttempt attribute)

name_without_orig (firexkit.task.FireXTask property) NameDuplicationException NoNameForEvent NotInCache

O

on_test_exit() (firexapp.testing.config_interpreter.ConfigInterpreter method) optional_args (firexkit.task.FireXTask property)

OptionalBoolean (class in firexapp.submit.submit) options (firexkit.chain.InjectArgs property) orig (firexkit.task.FireXTask attribute)

P

parent (firex_keeper.keeper_helper.FireXTreeTask attribute) parent_id (firex_keeper.keeper_helper.FireXTreeTask attribute) parse_task_docstring() (firexapp.info.InfoBaseApp class method) PathNotFoundException pause_point_requested() (firexkit.task.PauseTasks method) pause_tasks() (firexkit.task.TaskContext method) PAUSE_TASKS_ABOG_KEY (firexkit.task.PauseTasks attribute) pause_tasks_by_name (firexkit.task.PauseTasks attribute) PauseTasks (class in firexkit.task) pending_enqueued_children (firexkit.task.FireXTask property) PendingChildStrategy (class in firexkit.task) PkgVersionInfo (class in firexapp.discovery) PluginLoadError plugins_has() (in module firexapp.plugins) poll_until_dir_empty() (in module firexapp.common) poll_until_existing_file_not_empty() (in module firexapp.common) poll_until_file_exist() (in module firexapp.common) poll_until_file_not_empty() (in module firexapp.common) poll_until_path_exist() (in module firexapp.common)

populate_tests() (firexapp.testing.test_infra.FlowTestInfra class method) post_run_report() (firexapp.submit.reporting.ReportersRegistry class method) (firexapp.submit.reporting.ReportGenerator method) pre_load_was_run (firexapp.submit.arguments.InputConverter attribute) pre_run_report() (firexapp.submit.reporting.ReportersRegistry class method) (firexapp.submit.reporting.ReportGenerator static method) pre_task_run() (firexkit.task.FireXTask method) primary_worker_minimum_concurrency (firexapp.engine.default_celery_config.FxCeleryConfig attribute) primary_worker_name (firexapp.engine.default_celery_config.FxCeleryConfig attribute) print_argument_used() (firexapp.info.InfoBaseApp class method) print_available_microservices() (firexapp.info.InfoBaseApp class method) print_details() (firexapp.info.InfoBaseApp method) print_partial_task_matches() (firexapp.info.InfoBaseApp method) print_task_details() (firexapp.info.InfoBaseApp class method) priority (firexkit.task.FireXTask attribute) process_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) process_other_chain_args() (firexapp.submit.submit.SubmitBaseApp method) process_sync() (firexapp.submit.submit.SubmitBaseApp method) prune_duplicate_module_entry_points() (in module firexapp.discovery)

Q

qualify_firex_bin() (in module firexapp.common) Queue (firexkit.task.FxWorkerName attribute)

queue_and_sgroup() (firexkit.task.FxWorkerName method) queue_name (firexkit.task.FxWorkerName attribute) QueueItemType (class in firex_flame.controller)

R

random_int (firexapp.submit.uid.FireXIdParts attribute) rate_limit (firexkit.task.FireXTask attribute) read_from_file() (firexapp.fileregistry.FileRegistry static method) ready() (firexkit.result.FxEagerResult method) ready_for_tasks() (firexapp.submit.tracking_service.TrackingService method) ready_release_console() (firexapp.submit.tracking_service.TrackingService method) real_call() (firexkit.task.FireXTask method) redis_bin_dir (firexapp.engine.default_celery_config.FxCeleryConfig property) (firexapp.engine.default_celery_config.FxEnvVars attribute) register() (firexapp.submit.arguments.InputConverter class method) (firexkit.argument_conversion.ConverterRegister method) register_file() (firexapp.fileregistry.FileRegistry method) register_for_task() (firexkit.argument_conversion.ConverterRegister class method) reject_on_worker_lost (firexkit.task.FireXTask attribute) remove_inject_args() (firexkit.chain.SignatureX method) remove_task_logfile_handler() (firexkit.task.FireXTask method) render_template() (in module firexapp.common) report() (in module firexapp.submit.reporting) report_data() (in module firexapp.submit.reporting) ReportersRegistry (class in firexapp.submit.reporting) ReportGenerator (class in firexapp.submit.reporting) request_soft_time_limit (firexkit.task.FireXTask property) request_stack (firexkit.task.FireXTask attribute) RequeueingUndeliverableFilter (class in firexapp.submit.console) REQUIRE (firexkit.bag_of_goodies.ValidateArgs attribute) required_args (firexkit.task.FireXTask property) resolve_indirect() (firexkit.bag_of_goodies.BagOfGoodies class method) resolve_install_configs_args() (firexapp.submit.submit.SubmitBaseApp method) resolve_path() (firexapp.fileregistry.FileRegistry static method) resolve_plugin_paths() (firexapp.plugins.FxPluginRegistry class method) resources_dir (firexapp.engine.default_celery_config.FxCeleryConfig attribute) (firexapp.submit.uid.Uid property)

restart_celery_under_coverage() (in module firexapp.testing.coverage_plugin) result (firexkit.result.FxEagerResult property) result_backend (firexapp.engine.default_celery_config.FxCeleryConfig property) result_expires (firexapp.engine.default_celery_config.FxCeleryConfig attribute) result_serializer (firexapp.engine.default_celery_config.FxCeleryConfig attribute) results_dir (firexapp.testing.test_infra.FlowTestInfra attribute) retries (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexkit.task.TaskAttempt attribute) retry() (firexkit.task.FireXTask method) RetryFilter (class in firexapp.submit.console) return_args (firexkit.bag_of_goodies.BagOfGoodies property) return_keys (firexkit.task.FireXTask property) returns() (firexkit.result.FireXResults static method) ReturnsCodingException Revoke (firexkit.task.PendingChildStrategy attribute) revoke() (firexkit.result.FxEagerResult method) revoke_child() (firexkit.task.FireXTask method) revoke_non_ready() (firexkit.result.ManyFxAsyncResults method) revoke_nonready_children() (firexkit.task.FireXTask method) RevokedRequests (class in firexkit.revoke) root_logger_file_handler (firexkit.task.FireXTask property) root_orig (firexkit.task.FireXTask property) root_task (firexapp.engine.default_celery_config.FxCeleryConfig attribute) run() (firex_flame.event_broker_processor.BrokerEventConsumerThread method) (firexapp.application.FireXBaseApp method) (firexkit.task.FireXTask method) run_data (firexapp.testing.config_base.FlowTestConfiguration attribute) run_executable() (firexapp.testing.config_interpreter.ConfigInterpreter method) run_info() (firexapp.info.InfoBaseApp method) run_integration_test() (firexapp.testing.config_interpreter.ConfigInterpreter method) run_list() (firexapp.info.InfoBaseApp method) run_submit() (firexapp.submit.submit.SubmitBaseApp method) RunningModelDumper (class in firex_flame.controller)

S

s() (firexkit.task.FireXTask method) safe_create_initial_run_json() (in module firexapp.submit.submit) SchedulingDeadlockException second_warning (firexapp.application.ExitSignalHandler attribute) select_minimal_fx_env_from_os_env() (firexapp.engine.default_celery_config.FxEnvVars class method) self_destruct() (firexapp.submit.submit.SubmitBaseApp method) send_display_collapse() (firexkit.task.FireXTask method) send_event() (firexkit.task.FireXTask method) send_firex_event_raw() (firexkit.task.FireXTask method) send_firex_html() (firexkit.task.FireXTask method) send_flame() (firexkit.task.FireXTask method) send_kafka_mssg() (in module firex_blaze.blaze_event_consumer) send_pause_email_notification (firexkit.task.PauseTasks attribute) serializer (firexkit.task.FireXTask attribute) set_backend_task_start_time() (firexkit.task.FireXTask method) set_console_log_level() (in module firexapp.submit.console) set_fx_forget() (firexkit.result.FxAsyncResult method) set_fx_os_env() (firexapp.engine.default_celery_config.FxEnvVars method) set_label() (firexkit.chain.SignatureX method) set_plugins_env() (firexapp.plugins.FxPluginRegistry class method) set_priority() (firexkit.chain.SignatureX method) set_queue() (firexkit.chain.SignatureX method) set_soft_time_limit() (firexkit.chain.SignatureX method) set_use_cache() (firexkit.chain.SignatureX method) setUp() (firexapp.testing.test_infra.FlowTestInfra method) setup_console_logging() (in module firexapp.submit.console)

short_display() (firexkit.task.TaskAttempt method) short_name (firexkit.task.FireXTask property) short_name_without_orig (firexkit.task.FireXTask property) shutdown() (firexapp.celery_manager.CeleryManager method) signature (firexkit.task.TaskEnqueueSpec attribute) signature() (firexkit.task.FireXTask method) SignatureX (class in firexkit.chain) silent_mkdir() (in module firexapp.common) SingleArgDecorator (class in firexkit.argument_conversion) Singleton (class in firexapp.fileregistry) skip_test() (in module firexapp.testing.config_base) spawn_group (firexkit.task.FxWorkerName attribute) start() (firexapp.submit.tracking_service.TrackingService method) start_broker() (firexapp.submit.submit.SubmitBaseApp method) start_celery() (firexapp.submit.submit.SubmitBaseApp method) start_celery_worker() (firexapp.celery_manager.CeleryManager method) start_engine() (firexapp.submit.submit.SubmitBaseApp method) start_time() (firexkit.task.FireXTask method) start_tracking_services() (firexapp.submit.submit.SubmitBaseApp method) state (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexkit.result.FxEagerResult property) store_errors_even_if_ignored (firexkit.task.FireXTask attribute) store_parser_attributes() (firexapp.submit.submit.SubmitBaseApp method) strip_orig_from_name() (firexkit.task.FireXTask static method) SUBMISSION_LOGGING_FORMATTER (firexapp.submit.submit.SubmitBaseApp attribute) submit() (firexapp.submit.submit.SubmitBaseApp method) SubmitBaseApp (class in firexapp.submit.submit)

T

task_acks_late (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_attempt_from_str() (firexkit.task.TaskAttempt class method) task_convert() (firexkit.argument_conversion.ConverterRegister class method) task_default_queue (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_label (firexkit.task.FireXTask property) task_log_url (firexkit.task.FireXTask property) task_logfile (firexkit.task.FireXTask property) task_logging_dirpath (firexkit.task.FireXTask property) task_num (firex_keeper.keeper_helper.FireXTreeTask attribute) task_returns_to_tuple() (firexkit.result.FireXResults class method) task_serializer (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_soft_time_limit (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_track_started (firexapp.engine.default_celery_config.FxCeleryConfig attribute) task_uuid (firexkit.task.TaskAttempt attribute)

TaskAttempt (class in firexkit.task) TaskContext (class in firexkit.task) TaskDatabaseAggregatorThread (class in firex_keeper.keeper_event_consumer) TaskEnqueueSpec (class in firexkit.task) tearDown() (firexapp.testing.test_infra.FlowTestInfra method) terminate() (firexapp.celery_manager.CeleryManager class method) test_configs (firexapp.testing.test_infra.FlowTestInfra attribute) timestamp (firexapp.submit.uid.FireXIdParts attribute) timestamp_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) to_list() (in module firexapp.tasks.example) traceback (firex_keeper.keeper_helper.FireXTreeTask attribute) (firexkit.result.FxEagerResult property) track_started (firexkit.task.FireXTask attribute) TrackingService (class in firexapp.submit.tracking_service) typing (firexkit.task.FireXTask attribute)

U

Uid (class in firexapp.submit.uid) uid (firexapp.engine.default_celery_config.FxCeleryConfig property) (firexkit.task.FireXTask property) undecorate() (in module firexkit.task) undecorate_func() (in module firexkit.task) uniq_slug (firexkit.task.FxWorkerId attribute) unset_start_fx_celery_worker_env() (firexapp.celery_manager.CeleryManager class method)

update() (firexkit.bag_of_goodies.BagOfGoodies method) update_auto_inject_args() (firexkit.bag_of_goodies.AutoInjectRegistry method) update_env() (firexapp.celery_manager.CeleryManager method) update_parent_task_blocked_states() (firexkit.result.FxAsyncResult method) update_validated_args() (firexkit.bag_of_goodies.BagOfGoodies method) user (firexapp.submit.uid.FireXIdParts attribute) utcoffset (firex_keeper.keeper_helper.FireXTreeTask attribute) uuid (firex_keeper.keeper_helper.FireXTreeTask attribute)

V

Validate (firexkit.task.FireXTask attribute) validate_argument_applicability() (firexapp.submit.submit.SubmitBaseApp class method) ValidateArgs (class in firexkit.bag_of_goodies)

value (firexkit.bag_of_goodies.AutoInjectSpec attribute) verify_args() (firexkit.chain.SignatureX method) version() (firexapp.info.InfoBaseApp static method) viewers (firexapp.submit.uid.Uid property)

W

wait_for_all() (firexkit.result.ManyFxAsyncResults method) wait_for_any() (firexkit.result.ManyFxAsyncResults method) wait_for_any_children() (firexkit.task.FireXTask method) wait_for_children() (firexkit.task.FireXTask method) wait_for_running() (firexkit.result.ManyFxAsyncResults method) wait_for_shutdown() (firexapp.celery_manager.CeleryManager method) wait_for_specific_children() (firexkit.task.FireXTask method) wait_on_async_results() (in module firexkit.result) wait_tracking_services_pred() (firexapp.submit.submit.SubmitBaseApp method) wait_tracking_services_release_console_ready() (firexapp.submit.submit.SubmitBaseApp method) wait_tracking_services_task_ready() (firexapp.submit.submit.SubmitBaseApp method) wait_until() (in module firexapp.common) wait_until_pid_not_exist() (in module firexapp.common)

WaitLoopCallBack (class in firexkit.result) WaitOnChainTimeoutError whitelist_arguments() (in module firexapp.submit.arguments) WORKER (firexkit.task.FxWorkerTypes attribute) worker_autoscaler (firexapp.engine.default_celery_config.FxCeleryConfig attribute) worker_log_file (firexkit.task.FireXTask property) worker_log_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) worker_log_url (firexkit.task.FireXTask property) worker_prefetch_multiplier (firexapp.engine.default_celery_config.FxCeleryConfig attribute) worker_redirect_stdouts_level (firexapp.engine.default_celery_config.FxCeleryConfig attribute) worker_task_log_format (firexapp.engine.default_celery_config.FxCeleryConfig attribute) write_run_complete_file() (firexapp.submit.submit.SubmitBaseApp static method) write_task_log_html_header() (firexkit.task.FireXTask method) WritingFireXRunDbManager (class in firex_keeper.keeper_event_consumer)