MCPcopy Create free account

hub / github.com/airflow-plugins/Example-Airflow-DAGs / functions

Functions17 in github.com/airflow-plugins/Example-Airflow-DAGs

⨍ Functions 17◇ Types & classes 0
↓ 3 callersFunctioncreate_dag
(dag_id, schedule, hubspot_conn_id, redshift_conn_id,
etl/hubspot_to_redshift.py:184
↓ 3 callersFunctioncreate_dag
(dag_id, schedule, marketo_conn_id, redshift_conn_id,
etl/marketo_to_redshift.py:53
↓ 3 callersFunctionget_conn
(conn_id, session=None)
poc/selenium_example.py:73
↓ 2 callersFunctionprocess_collection
(collection)
etl/mongo_to_redshift/mongo_to_redshift.py:57
↓ 1 callersFunction_convertSchema
(schema)
etl/mongo_to_redshift/collections/_collection_processing.py:53
↓ 1 callersFunction_prepareData
(data, subtable='')
etl/mongo_to_redshift/collections/_collection_processing.py:12
↓ 1 callersFunctiondbt_dag
(start_date, schedule_interval, default_args)
poc/dbt_example.py:79
↓ 1 callersFunctionmake_dbt_task
(model_name)
poc/dbt_example.py:83
↓ 1 callersFunctionprojection
(d, parent_key='', sep='_', subtable='')
etl/mongo_to_redshift/collections/_collection_processing.py:31
↓ 1 callersFunctionschema
(d, parent_key='', sep='_')
etl/mongo_to_redshift/collections/_collection_processing.py:43
Functioncheck_for_file_py
(**kwargs)
etl/sftp_to_mongo.py:68
Functioncheck_py
(session=None, **kwargs)
system/rate_limit_reset.py:43
Functioncreate_dag
Accepts a customer parameters dict and overrides default args to create a DAG object Returns: DAG() Object
poc/dynamic_dag_example.py:38
Functionflatten_py
(**kwargs)
etl/mongo_to_redshift/mongo_to_redshift.py:77
Functionimap_py
(**kwargs)
poc/selenium_example.py:64
Functionimap_py
(**kwargs)
poc/imap_example.py:50
Functiontransform_py
(**kwargs)
etl/sftp_to_mongo.py:83