Index

_

_account (sosw.app.Processor property) _describe_table() (sosw.components.dynamo_db.DynamoDbClient method)

_parse_filter_expression() (sosw.components.dynamo_db.DynamoDbClient method) _query_constructor() (sosw.components.dynamo_db.DynamoDbClient method) _region (sosw.app.Processor property)

A

add_running_tasks_for_labourer() (sosw.managers.ecology.EcologyManager method) any_events_rules_enabled() (sosw.components.siblings.SiblingsManager method)

apply_job_schema() (sosw.scheduler.Scheduler method) archive_tasks() (sosw.scavenger.Scavenger method) AwsSigV4RequestGenerator (class in sosw.components.sigv4)

B

batch_get_items_one_table() (sosw.components.dynamo_db.DynamoDbClient method)

benchmark() (in module sosw.components.benchmark)

C

call_boto_secrets_with_pagination() (sosw.components.config.SecretsManager method) call_boto_with_pagination() (sosw.components.config.SSMConfig method) camel_case_to_underscore() (in module sosw.components.helpers) chunk_dates() (sosw.scheduler.Scheduler method) chunk_job() (sosw.scheduler.Scheduler method) chunks() (in module sosw.components.helpers) clean_dynamo_table() (in module sosw.components.dynamo_db) commit() (sosw.components.sns.SnsManager method) compare_message_attributtes() (sosw.components.sns.SnsManager method)

ConfigSource (class in sosw.components.config) construct_dates_from_event() (in module sosw.components.helpers) construct_job_data() (sosw.scheduler.Scheduler method) construct_payload_for_task() (sosw.managers.task.TaskManager method) convert_string_to_words() (in module sosw.components.helpers) count_running_tasks_for_labourer() (sosw.managers.ecology.EcologyManager method) create() (sosw.components.dynamo_db.DynamoDbClient method) create_subscription() (sosw.components.sns.SnsManager method) create_task() (sosw.managers.task.TaskManager method) create_topic() (sosw.components.sns.SnsManager method)

D

delete() (sosw.components.dynamo_db.DynamoDbClient method) dict_to_dynamo() (sosw.components.dynamo_db.DynamoDbClient method) die() (sosw.app.Processor method) docs.hello module

dunder_to_dict() (in module sosw.components.helpers) dynamo_to_dict() (sosw.components.dynamo_db.DynamoDbClient method) DynamoConfig (class in sosw.components.config) DynamoDbClient (class in sosw.components.dynamo_db)

E

EcologyManager (class in sosw.managers.ecology)

Essential (class in sosw.essential) extract_job_from_payload() (sosw.scheduler.Scheduler method)

F

fetch_metric_stats() (sosw.managers.ecology.EcologyManager method)

first_or_none() (in module sosw.components.helpers)

G

get_and_lock_queue_file() (sosw.scheduler.Scheduler method) get_approximate_concurrent_executions() (sosw.components.siblings.SiblingsManager method) get_authorization_header() (sosw.components.sigv4.AwsSigV4RequestGenerator method) get_aws_sigv4_headers() (sosw.components.sigv4.AwsSigV4RequestGenerator method) get_by_query() (sosw.components.dynamo_db.DynamoDbClient method) get_by_scan() (sosw.components.dynamo_db.DynamoDbClient method) get_by_scan_generator() (sosw.components.dynamo_db.DynamoDbClient method) get_canonical_headers() (sosw.components.sigv4.AwsSigV4RequestGenerator method) get_canonical_querystring() (sosw.components.sigv4.AwsSigV4RequestGenerator static method) get_canonical_uri() (sosw.components.sigv4.AwsSigV4RequestGenerator static method) get_capacity() (sosw.components.dynamo_db.DynamoDbClient method) get_completed_tasks_for_labourer() (sosw.managers.task.TaskManager method) get_config() (sosw.app.Processor static method) (sosw.components.config.DynamoConfig method) (sosw.components.config.SSMConfig method) get_count_of_running_tasks_for_labourer() (sosw.managers.task.TaskManager method) get_credentials_by_prefix() (sosw.components.config.DynamoConfig method) (sosw.components.config.SSMConfig method) get_db_field_name() (sosw.managers.task.TaskManager method) (sosw.orchestrator.Orchestrator method) (sosw.scavenger.Scavenger method) (sosw.scheduler.Scheduler method) get_desired_invocation_number_for_labourer() (sosw.orchestrator.Orchestrator method) get_expired_tasks_for_labourer() (sosw.managers.task.TaskManager method) get_headers_and_credential_date() (sosw.components.sigv4.AwsSigV4RequestGenerator static method) get_health() (sosw.managers.ecology.EcologyManager method) get_index_from_list() (sosw.scheduler.Scheduler static method)

get_invoked_tasks_for_labourer() (sosw.managers.task.TaskManager method) get_isolate_attributes_from_job() (sosw.scheduler.Scheduler static method) get_labourer_average_duration() (sosw.managers.ecology.EcologyManager method) get_labourer_status() (sosw.managers.ecology.EcologyManager method) get_labourers() (sosw.managers.task.TaskManager method) (sosw.orchestrator.Orchestrator method) get_lambda_handler() (in module sosw.app) get_length_of_queue_for_labourer() (sosw.managers.task.TaskManager method) get_list_of_multiple_or_one_or_empty_from_dict() (in module sosw.components.helpers) get_max_labourer_duration() (sosw.managers.ecology.EcologyManager method) get_message_attribute() (sosw.components.sns.SnsManager static method) get_message_dict_from_sns_event() (in module sosw.components.helpers) get_newest_greenfield_for_labourer() (sosw.managers.task.TaskManager method) get_next_chunkable_attr() (sosw.scheduler.Scheduler method) get_next_for_labourer() (sosw.managers.task.TaskManager method) get_oldest_greenfield_for_labourer() (sosw.managers.task.TaskManager method) get_one_from_dict() (in module sosw.components.helpers) get_one_or_none_from_dict() (in module sosw.components.helpers) get_payload_hash() (sosw.components.sigv4.AwsSigV4RequestGenerator static method) get_running_tasks_for_labourer() (sosw.managers.task.TaskManager method) get_secrets_credentials() (sosw.components.config.SecretsManager method) get_signature_key() (sosw.components.sigv4.AwsSigV4RequestGenerator method) get_stats() (sosw.app.Processor method) (sosw.components.dynamo_db.DynamoDbClient method) (sosw.managers.ecology.EcologyManager method) get_table_indexes() (sosw.components.dynamo_db.DynamoDbClient method) get_table_keys() (sosw.components.dynamo_db.DynamoDbClient method) get_task_by_id() (sosw.managers.task.TaskManager method)

H

hello() (in module docs.hello)

I

identify_dynamo_capacity() (sosw.components.dynamo_db.DynamoDbClient method) init_config() (sosw.app.Processor method) (sosw.essential.Essential method) initialize_from_job_schema() (sosw.scheduler.Scheduler method)

invoke_for_labourer() (sosw.orchestrator.Orchestrator method) invoke_task() (sosw.managers.task.TaskManager method) is_event_from_sns() (in module sosw.components.helpers) is_valid_date() (in module sosw.components.helpers) is_valid_task() (sosw.managers.task.TaskManager method)

L

LambdaGlobals (class in sosw.app)

last_week() (sosw.scheduler.Scheduler method) last_x_days() (sosw.scheduler.Scheduler method)

M

make_hash() (in module sosw.components.helpers) mark_task_as_completed() (sosw.worker.Worker method) mark_task_as_failed() (sosw.worker.Worker method) mark_task_invoked() (sosw.managers.task.TaskManager method) MetaHandler (class in sosw.managers.meta_handler) module docs.hello sosw.app sosw.components.benchmark sosw.components.config sosw.components.dynamo_db sosw.components.helpers sosw.components.siblings sosw.components.sigv4 sosw.components.sns sosw.essential sosw.managers.ecology sosw.managers.meta_handler sosw.managers.task sosw.orchestrator sosw.scavenger sosw.scheduler sosw.worker sosw.worker_assistant

move_task_to_retry_table() (sosw.managers.task.TaskManager method) (sosw.scavenger.Scavenger method)

N

needs_chunking() (sosw.scheduler.Scheduler method)

nested_dict_from_keys() (in module sosw.components.helpers)

O

Orchestrator (class in sosw.orchestrator)

P

parse_job_to_file() (sosw.scheduler.Scheduler method) patch() (sosw.components.dynamo_db.DynamoDbClient method) pop_rows_from_file() (sosw.scheduler.Scheduler static method) post() (sosw.managers.meta_handler.MetaHandler method)

previous_x_days() (sosw.scheduler.Scheduler method) process_file() (sosw.scheduler.Scheduler method) Processor (class in sosw.app) put() (sosw.components.dynamo_db.DynamoDbClient method)

R

recursive_matches_extract() (in module sosw.components.helpers) recursive_matches_soft() (in module sosw.components.helpers) recursive_matches_strict() (in module sosw.components.helpers) recursive_update() (in module sosw.components.helpers) register_labourers() (sosw.managers.task.TaskManager method) register_task_manager() (sosw.managers.ecology.EcologyManager method) remote_queue_file (sosw.scheduler.Scheduler property)

remote_queue_locked_file (sosw.scheduler.Scheduler property) reset_stats() (sosw.app.Processor method) (sosw.components.dynamo_db.DynamoDbClient method) (sosw.managers.ecology.EcologyManager method) retry_task() (sosw.managers.task.TaskManager method) retry_tasks() (sosw.scavenger.Scavenger method) rstrip_all() (in module sosw.components.helpers)

S

Scavenger (class in sosw.scavenger) Scheduler (class in sosw.scheduler) SecretsManager (class in sosw.components.config) send_message() (sosw.components.sns.SnsManager method) set_client_attr() (sosw.components.sns.SnsManager method) set_message_attributes() (sosw.components.sns.SnsManager method) set_queue_file() (sosw.scheduler.Scheduler method) set_separator() (sosw.components.sns.SnsManager method) SiblingsManager (class in sosw.components.siblings) sleep_db() (sosw.components.dynamo_db.DynamoDbClient method) small_int_from_string() (in module sosw.components.helpers) SnsManager (class in sosw.components.sns) sosw.app module sosw.components.benchmark module sosw.components.config module sosw.components.dynamo_db module sosw.components.helpers module sosw.components.siblings module

sosw.components.sigv4 module sosw.components.sns module sosw.essential module sosw.managers.ecology module sosw.managers.meta_handler module sosw.managers.task module sosw.orchestrator module sosw.scavenger module sosw.scheduler module sosw.worker module sosw.worker_assistant module spawn_sibling() (sosw.components.siblings.SiblingsManager method) SSMConfig (class in sosw.components.config) sufficient_execution_time_left (sosw.scheduler.Scheduler property)

T

TaskManager (class in sosw.managers.task) today() (sosw.scheduler.Scheduler method)

transact_write() (sosw.components.dynamo_db.DynamoDbClient method) trim_arn_to_account() (in module sosw.components.helpers) trim_arn_to_name() (in module sosw.components.helpers)

U

unwrap_event_recursively() (in module sosw.components.helpers) update() (sosw.components.dynamo_db.DynamoDbClient method)

update_config() (sosw.components.config.DynamoConfig method) (sosw.components.config.SSMConfig method) upload_and_unlock_queue_file() (sosw.scheduler.Scheduler method)

V

validate_account_to_dashed() (in module sosw.components.helpers) validate_account_to_int() (in module sosw.components.helpers) validate_date_from_something() (in module sosw.components.helpers) validate_date_list_from_event_or_days_back() (in module sosw.components.helpers) validate_datetime_from_something() (in module sosw.components.helpers)

validate_list_of_numbers_from_csv() (in module sosw.components.helpers) validate_list_of_vals() (sosw.scheduler.Scheduler method) validate_list_of_words_from_csv_or_list() (in module sosw.components.helpers) validate_string_matches_datetime_format() (in module sosw.components.helpers) validate_uuid4() (in module sosw.components.helpers)

W

Worker (class in sosw.worker)

WorkerAssistant (class in sosw.worker_assistant)

X

x_days_back() (sosw.scheduler.Scheduler method)

Y

yesterday() (sosw.scheduler.Scheduler method)