Index

A

abog (firexkit.task.FireXTask property) add_task_logfile_handler() (firexkit.task.FireXTask method) add_task_result_with_report_to_db() (firexkit.task.FireXTask method) (in module firexkit.task)

all_args (firexkit.task.FireXTask property) apply_async() (firexkit.task.FireXTask method) args (firexkit.task.FireXTask property) ArgumentConversionException

B

bag (firexkit.task.FireXTask property) BagOfGoodies (class in firexkit.bag_of_goodies)

banner() (in module firexkit.task) Block (firexkit.task.PendingChildStrategy attribute) bound_args (firexkit.task.FireXTask property)

C

cache_call() (firexkit.task.FireXTask method) CacheResultNotPopulatedYetInRedis called_as_orig (firexkit.task.FireXTask property) ChainException ChainInterruptedByZombieTaskException ChainInterruptedException ChainRevokedException ChainRevokedPreRunException CircularDependencyException clear() (firexkit.task.DictWillNotAllowWrites method)

climb_up_until_null_parent() (in module firexkit.result) Continue (firexkit.task.PendingChildStrategy attribute) convert() (firexkit.argument_conversion.ConverterRegister method) convert_cached_results() (firexkit.task.FireXTask class method) convert_results_if_returns_defined_by_task_definition() (firexkit.task.FireXTask method) convert_returns_to_dict() (firexkit.task.FireXTask class method) convert_to_serializable() (in module firexkit.task) ConverterRegister (class in firexkit.argument_conversion) ConverterRegistrationException create_collapse_ops() (in module firexkit.task) create_flame_config() (in module firexkit.task)

D

default_bound_args (firexkit.task.FireXTask property) default_use_cache (firexkit.task.FireXTask property) DictWillNotAllowWrites (class in firexkit.task) disable_all_async_results() (in module firexkit.result)

disable_async_result() (in module firexkit.result) duration() (firexkit.task.FireXTask method) DyanmicReturnsNotADict DYNAMIC_RETURN (firexkit.task.FireXTask attribute)

E

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_child_once() (firexkit.task.FireXTask method)

enqueue_child_once_and_extract() (firexkit.task.FireXTask method) enqueue_in_parallel() (firexkit.task.FireXTask method) enqueue_opts (firexkit.task.TaskEnqueueSpec attribute) enqueued_children (firexkit.task.FireXTask property) expand_self_op() (in module firexkit.task)

F

file_logging_dirpath (firexkit.task.FireXTask property) final_call() (firexkit.task.FireXTask method) find_all_unsuccessful() (in module firexkit.result) find_unsuccessful_in_chain() (in module firexkit.result) firexkit.argument_conversion module firexkit.bag_of_goodies module firexkit.chain module firexkit.result module firexkit.revoke module firexkit.task module

FireXTask (class in firexkit.task) first_non_chain_interrupted_exception() (in module firexkit.result) flame() (in module firexkit.task) flame_collapse() (in module firexkit.task) flame_collapse_formatter() (in module firexkit.task) forget_chain_results() (in module firexkit.result) forget_child_result() (firexkit.task.FireXTask method) forget_enqueued_children_results() (firexkit.task.FireXTask method) forget_single_async_result() (in module firexkit.result) forget_specific_children_results() (firexkit.task.FireXTask method) forget_subtree_results() (in module firexkit.result) frequency (firexkit.result.WaitLoopCallBack attribute) from_plugin (firexkit.task.FireXTask property) func (firexkit.result.WaitLoopCallBack attribute)

G

get_all_children() (in module firexkit.result) get_attr_unwrapped() (in module firexkit.task) get_bag() (firexkit.bag_of_goodies.BagOfGoodies method) get_cache_enabled_uid_dbkey() (in module firexkit.task) get_chain_head() (in module firexkit.revoke) 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_enqueue_child_once_count_dbkey() (in module firexkit.task) get_enqueue_child_once_uid_dbkey() (in module firexkit.task) get_label() (in module firexkit.chain) get_module_file_location() (firexkit.task.FireXTask method) get_register() (firexkit.argument_conversion.ConverterRegister class method) get_result_id() (in module firexkit.result) get_result_logging_name() (in module firexkit.result) get_results() (in module firexkit.result) get_results_with_default() (in module firexkit.result)

get_revoked_list_from_app() (firexkit.revoke.RevokedRequests class method) get_short_name() (firexkit.task.FireXTask static method) get_short_name_without_orig() (firexkit.task.FireXTask class method) get_starttime_dbkey() (in module firexkit.task) get_task_flame_configs() (firexkit.task.FireXTask method) get_task_info_from_result() (in module firexkit.result) 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_task_name_from_result() (in module firexkit.result) get_task_postrun_info() (in module firexkit.result) get_task_queue_from_result() (in module firexkit.result) get_task_results() (in module firexkit.result) get_task_return_keys() (firexkit.task.FireXTask method) get_task_start_time() (in module firexkit.task) get_tasks_inputs_from_result() (in module firexkit.result) get_tasks_names_from_results() (in module firexkit.result) get_time_from_task_start() (in module firexkit.task) get_visit_order() (firexkit.argument_conversion.ConverterRegister method)

H

handle_exception() (firexkit.task.FireXTask method)

has_report_meta() (firexkit.task.FireXTask method)

I

ignore_result (firexkit.task.FireXTask attribute) IllegalTaskNameException INDIRECT_ARG_CHAR (firexkit.bag_of_goodies.BagOfGoodies attribute) initialize_context() (firexkit.task.FireXTask method) inject_abog (firexkit.task.TaskEnqueueSpec attribute) InjectArgs (class in firexkit.chain) instance() (firexkit.revoke.RevokedRequests class method)

InvalidChainArgsException is_async_result_monkey_patched_to_track() (in module firexkit.result) is_cache_enabled() (firexkit.task.FireXTask method) is_dynamic_return() (firexkit.task.FireXTask class method) is_jsonable() (in module firexkit.task) is_result_ready() (in module firexkit.result) is_revoked() (firexkit.revoke.RevokedRequests method)

K

kwargs (firexkit.result.WaitLoopCallBack attribute) (firexkit.task.FireXTask property)

L

last_causing_chain_interrupted_exception() (in module firexkit.result)

list_converters() (firexkit.argument_conversion.ConverterRegister class method) logs_dir_for_worker (firexkit.task.FireXTask property)

M

map_args() (firexkit.task.FireXTask method) map_input_args_kwargs() (firexkit.task.FireXTask method) mark_queues_ready() (in module firexkit.result) mark_task_postrun() (in module firexkit.result) MESSAGE (firexkit.result.ChainInterruptedException attribute) (firexkit.result.ChainRevokedException attribute) (firexkit.result.MultipleFailuresException attribute) MissingConverterDependencyError

module firexkit.argument_conversion firexkit.bag_of_goodies firexkit.chain firexkit.result firexkit.revoke firexkit.task monkey_patch_async_result_to_track_instances() (in module firexkit.result) MultipleFailuresException

N

name_without_orig (firexkit.task.FireXTask property) NameDuplicationException

nonready_enqueued_children (firexkit.task.FireXTask property) NotInCache

O

optional_args (firexkit.task.FireXTask property)

P

parse_signature() (in module firexkit.task) pending_enqueued_children (firexkit.task.FireXTask property) PendingChildStrategy (class in firexkit.task) pop() (firexkit.bag_of_goodies.BagOfGoodies method) (firexkit.task.DictWillNotAllowWrites method) popitem() (firexkit.task.DictWillNotAllowWrites method)

populate_task_info() (in module firexkit.result) post_task_run() (firexkit.task.FireXTask method) pre_task_run() (firexkit.task.FireXTask method) print_postcall_header() (firexkit.task.FireXTask method) print_precall_header() (firexkit.task.FireXTask method) priority (firexkit.task.FireXTask attribute)

R

rate_limit (firexkit.task.FireXTask attribute) real_call() (firexkit.task.FireXTask method) register() (firexkit.argument_conversion.ConverterRegister method) register_for_task() (firexkit.argument_conversion.ConverterRegister class method) reject_on_worker_lost (firexkit.task.FireXTask attribute) remove_task_logfile_handler() (firexkit.task.FireXTask method) request_soft_time_limit (firexkit.task.FireXTask property) request_stack (firexkit.task.FireXTask attribute) required_args (firexkit.task.FireXTask property) resolve_circular_indirect_references() (firexkit.bag_of_goodies.BagOfGoodies method) results2tuple() (in module firexkit.result) retry() (firexkit.task.FireXTask method)

RETURN_KEYS_KEY (firexkit.task.FireXTask attribute) returns() (in module firexkit.chain) ReturnsCodingException Revoke (firexkit.task.PendingChildStrategy attribute) revoke_child() (firexkit.task.FireXTask method) revoke_nodes_up_to_parent() (in module firexkit.revoke) revoke_nonready_children() (firexkit.task.FireXTask method) RevokedRequests (class in firexkit.revoke) root_logger (firexkit.task.FireXTask property) root_logger_file_handler (firexkit.task.FireXTask property) root_orig (firexkit.task.FireXTask property) run() (firexkit.task.FireXTask method)

S

send_block_task_states_to_caller_task() (in module firexkit.result) send_display_collapse() (firexkit.task.FireXTask method) send_event() (firexkit.task.FireXTask method) send_firex_data() (firexkit.task.FireXTask method) send_firex_event_raw() (firexkit.task.FireXTask method) send_firex_html() (firexkit.task.FireXTask method) send_task_completed_event() (in module firexkit.task) serializer (firexkit.task.FireXTask attribute) set_execution_options() (in module firexkit.chain) set_label() (in module firexkit.chain) set_priority() (in module firexkit.chain) set_queue() (in module firexkit.chain) set_soft_time_limit() (in module firexkit.chain)

set_use_cache() (in module firexkit.chain) setdefault() (firexkit.task.DictWillNotAllowWrites method) short_name (firexkit.task.FireXTask property) short_name_without_orig (firexkit.task.FireXTask property) signature (firexkit.task.TaskEnqueueSpec attribute) signature() (firexkit.task.FireXTask method) SingleArgDecorator (class in firexkit.argument_conversion) split_for_signature() (firexkit.bag_of_goodies.BagOfGoodies method) start_time() (firexkit.task.FireXTask method) statsd_task_postrun() (in module firexkit.task) statsd_task_prerun() (in module firexkit.task) statsd_task_revoked() (in module firexkit.task) store_errors_even_if_ignored (firexkit.task.FireXTask attribute) strip_orig_from_name() (firexkit.task.FireXTask static method)

T

task_context() (firexkit.task.FireXTask method) task_convert() (firexkit.argument_conversion.ConverterRegister class method) 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_prerequisite() (in module firexkit.task) TaskContext (class in firexkit.task) TaskEnqueueSpec (class in firexkit.task) teardown_monkey_patch_async_result_to_track_instances() (in module firexkit.result) track_started (firexkit.task.FireXTask attribute) typing (firexkit.task.FireXTask attribute)

U

uid (firexkit.task.FireXTask property) UidNotInjectedInAbog undecorate() (in module firexkit.task) undecorate_func() (in module firexkit.task)

update() (firexkit.bag_of_goodies.BagOfGoodies method) (firexkit.revoke.RevokedRequests method) (firexkit.task.DictWillNotAllowWrites method) update_firex_data() (firexkit.task.FireXTask method) update_task_name() (in module firexkit.result)

V

verify_chain_arguments() (in module firexkit.chain)

W

wait_for_any_children() (firexkit.task.FireXTask method) wait_for_any_results() (in module firexkit.result) wait_for_children() (firexkit.task.FireXTask method) wait_for_running_tasks_from_results() (in module firexkit.result) wait_for_specific_children() (firexkit.task.FireXTask method) wait_on_async_results() (in module firexkit.result) wait_on_async_results_and_maybe_raise() (in module firexkit.result)

WaitLoopCallBack (class in firexkit.result) WaitOnChainTimeoutError warn() (firexkit.task.DictWillNotAllowWrites method) was_queue_ready() (in module firexkit.result) worker_log_file (firexkit.task.FireXTask property) worker_log_url (firexkit.task.FireXTask property) write_task_log_html_header() (firexkit.task.FireXTask method)