airflow
airflow copied to clipboard
apache
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
### Apache Airflow version 2.3.4 ### What happened If you try to use `Variable.get` from inside of a custom Timetable, the Scheduler will break with errors like: ``` scheduler |...
Snapshot: ------ closes: #26427 related: #26461 --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-guidelines)** for more information. In case of fundamental code changes, an Airflow Improvement Proposal...
### Description 1. I need a "workspace" or "DAG Group" to support multi-tenancy, there will be different projects within the organization that I hope can be isolated from each other...
**Apache Airflow version**: 1.10.9 **Kubernetes version (if you are using kubernetes)** (use `kubectl version`): Server: v1.10.13, Client: v1.17.0 **Environment**: - **Cloud provider or hardware configuration**: AWS - **OS** (e.g. from...
closes: #24618 Adds support for oracledb thick mode in the oracle provider, along with the option to set some defaults supported by oracledb (fetch_decimals and fetch_lobs).
* Don't log entire executor_config unless it fail. Today, it occupies close to 100 lines on each log entry every time a pod is launched. * Only log Pending events...
The current `airflow dag test` command is insufficient for an iterative local workflow when developing dags. The current system relies on running a backfill job which a) is extremely slow...
This PR tries to fix issue stated in https://github.com/apache/airflow/issues/26207 . Google videointelligence package requirements in google provider is set to be >2.0.0
This allows us to derive the dag run logical date from the event timestamp rather than the queue record created_at, which allows us to be slightly more precise when associating...
Allow using `params` in expanding kwargs. Fix #24014. Syntax unlocked: ```python # Two tasks with params={"a": 1} and params={"b": 2}. MyOperator.partial(task_id="t").expand(params=[{"a": 1}, {"b": 2}]) # Two tasks with params={"a": 0,...
