airflow_api_plugin

airflow_api_plugin copied to clipboard

# Context I need to run an API using both Macro: `{{ execution_date }}` and `{{ next_execution_date }}` to run some queries, I am using this json below to POST:...

Oracy

get dag run status by dag_id and run_id

1

dwai1714

irvifa

removing "dags" when instantiating the DagBag class, as no dags are returned if "dags" is included. Issues found when Airflow-webserver is running as a service.

smogili1

Naive datetime issue

1

When setting a default_timezone other than UTC, dag_run API will return naive datetime error. Can be fixed by adding: `from pytz import timezone` and replacing line 178 and 179 with:...

vic614

Line 102 and Line 219 : `dagbag = DagBag('dags')` replace with : ` dag_home = settings.conf.get('core', 'dags_folder')` ` dagbag = DagBag(dag_home)` This will solve empty dag response

vic614

Can't pass conf to dag

3

Hi, I'm using your plugin and I got a hard time passing conf to my dag. My dag runs without problems in CLI `airflow trigger_dag test --conf '{"workingDir":"/tmp/aZEf"}'` . However,...

Dutisto

Endpoints to: get a specific dag from the id, change paused status, create and delete connections

4

This pull request overlaps with #2 , the approach followed here is to use a PUT request with a very simple payload which directly reflects the state change. From the...

GiovanniPaoloGibilisco

benjamingregory