Index

A

allow_run_from_web_ui() (in module mara_pipelines.config)

already_processed_files() (in module mara_pipelines.incremental_processing.processed_files)

B

base_url() (in module mara_pipelines.config)

bash_command_string() (in module mara_pipelines.config)

C

Command (class in mara_pipelines.pipelines)

Copy (class in mara_pipelines.commands.sql) CopyIncrementally (class in mara_pipelines.commands.sql)

D

data_dir() (in module mara_pipelines.config) default_db_alias() (in module mara_pipelines.config)

default_task_max_retries() (in module mara_pipelines.config) delete() (in module mara_pipelines.incremental_processing.file_dependencies) (in module mara_pipelines.incremental_processing.incremental_copy_status)

E

Event (class in mara_pipelines.events) event_handlers() (in module mara_pipelines.config)

EventHandler (class in mara_pipelines.events) ExecutePython (class in mara_pipelines.commands.python) ExecuteSQL (class in mara_pipelines.commands.sql)

F

find_node() (in module mara_pipelines.pipelines)

first_date() (in module mara_pipelines.config)

G

get_last_comparison_value() (in module mara_pipelines.incremental_processing.incremental_copy_status)

GZIP (mara_pipelines.commands.files.Compression attribute)

H

hash() (in module mara_pipelines.incremental_processing.file_dependencies)

I

is_modified() (in module mara_pipelines.incremental_processing.file_dependencies)

L

last_date() (in module mara_pipelines.config)

M

mara_pipelines module mara_pipelines.commands module mara_pipelines.commands.bash module mara_pipelines.commands.files module mara_pipelines.commands.python module mara_pipelines.commands.sql module mara_pipelines.config module mara_pipelines.events module mara_pipelines.incremental_processing.file_dependencies module mara_pipelines.incremental_processing.incremental_copy_status module mara_pipelines.incremental_processing.processed_files module mara_pipelines.incremental_processing.reset module mara_pipelines.parallel_tasks module mara_pipelines.parallel_tasks.files module

mara_pipelines.parallel_tasks.python module mara_pipelines.parallel_tasks.sql module mara_pipelines.pipelines module mara_pipelines.shell module max_number_of_parallel_tasks() (in module mara_pipelines.config) module mara_pipelines mara_pipelines.commands mara_pipelines.commands.bash mara_pipelines.commands.files mara_pipelines.commands.python mara_pipelines.commands.sql mara_pipelines.config mara_pipelines.events mara_pipelines.incremental_processing.file_dependencies mara_pipelines.incremental_processing.incremental_copy_status mara_pipelines.incremental_processing.processed_files mara_pipelines.incremental_processing.reset mara_pipelines.parallel_tasks mara_pipelines.parallel_tasks.files mara_pipelines.parallel_tasks.python mara_pipelines.parallel_tasks.sql mara_pipelines.pipelines mara_pipelines.shell

N

NONE (mara_pipelines.commands.files.Compression attribute)

notify_configured_event_handlers() (in module mara_pipelines.events)

P

ParallelExecutePython (class in mara_pipelines.parallel_tasks.python) ParallelExecuteSQL (class in mara_pipelines.parallel_tasks.sql) ParallelReadFile (class in mara_pipelines.parallel_tasks.files)

ParallelReadSqlite (class in mara_pipelines.parallel_tasks.files) ParallelRunFunction (class in mara_pipelines.parallel_tasks.python) password_masks() (in module mara_pipelines.config) Pipeline (class in mara_pipelines.pipelines)

R

ReadFile (class in mara_pipelines.commands.files) ReadScriptOutput (class in mara_pipelines.commands.files) ReadSQLite (class in mara_pipelines.commands.files) reset_incremental_processing() (in module mara_pipelines.incremental_processing.reset)

root_pipeline() (in module mara_pipelines.config) run_log_retention_in_days() (in module mara_pipelines.config) run_shell_command() (in module mara_pipelines.shell) RunBash (class in mara_pipelines.commands.bash) RunFunction (class in mara_pipelines.commands.python)

S

sed_command() (in module mara_pipelines.shell)

slack_token() (in module mara_pipelines.config) system_statistics_collection_period() (in module mara_pipelines.config)

T

TAR_GZIP (mara_pipelines.commands.files.Compression attribute)

Task (class in mara_pipelines.pipelines) track_processed_file() (in module mara_pipelines.incremental_processing.processed_files)

U

update() (in module mara_pipelines.incremental_processing.file_dependencies) (in module mara_pipelines.incremental_processing.incremental_copy_status)

W

WriteFile (class in mara_pipelines.commands.files)

Z

ZIP (mara_pipelines.commands.files.Compression attribute)