Base operators

class airflow_plugins.operators.base.BashOperator(bash_command=None, *args, **kwargs)

Bash Operator

class airflow_plugins.operators.base.ExecutableOperator(task_id, owner='Airflow', email=None, email_on_retry=True, email_on_failure=True, retries=0, retry_delay=datetime.timedelta(0, 300), retry_exponential_backoff=False, max_retry_delay=None, start_date=None, end_date=None, schedule_interval=None, depends_on_past=False, wait_for_downstream=False, dag=None, params=None, default_args=None, adhoc=False, priority_weight=1, queue='default', pool=None, sla=None, execution_timeout=None, on_failure_callback=None, on_success_callback=None, on_retry_callback=None, trigger_rule='all_success', resources=None, run_as_user=None, *args, **kwargs)

Simple wrapper around command line executable programs with helper functions to add options, flags and arguments.

add_flag(flag_name)

Add boolean flag option used as enabled or disabled state

add_option(option_name, value)

Add option to command

class airflow_plugins.operators.base.PostgresOperator(sql=None, *args, **kwargs)

Run SQL on Postgresql based systems.