Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
APACHE-2.0 License
Bot releases are hidden (Show)
Published by jedcunningham over 2 years ago
annotations
on volumeClaimTemplates
(#23433)topologySpreadConstraints
to Helm Chart (#22712)securityContext
config for Redis to Helm chart (#22182)annotations
on Helm DAG PVC (#22261)subPath
for DAGs volume mount (#22323)auth_type
in auth_file
in PgBouncer Helm configuration (#21999)extraVolumeMounts
to Flower (#22414)PodDisruptionBudget
(#21735)resultBackendSecretName
warning in Helm production docs (#23307)2.3.0
(#23386)Published by ephraimbuddy over 2 years ago
requirements.txt
in Python Operators (#17349)SmoothOperator
(#22813)execution_timeout
configurable (#22389)ti_deps
rules (#22698)dag-processor
cli command (#22305)ignore_first_depends_on_past
for scheduled jobs (#22491)list-import-errors
to airflow dags
command (#22084)standalone_dag_processor
config is True. (#21731)celery.task_timeout_error
metric (#21602)db downgrade
cli command (#21596)ALL_SKIPPED
trigger rule (#21662)db clean
CLI command for purging old data (#20838)celery_logging_level
(#21506)ShortCircuitOperator
configurability for respecting downstream trigger rules (#20044)dag_id_pattern
parameter to the /dags
endpoint (#18924)--skip-init
to db reset command (#22989).airflowignore
files (#21392) (#22051)has_access
decorator by ~200ms (#22858)try_number
in airflow vars (#22297)airflow dags list
CLI command (#21991)is_zipfiles
in refresh_dag (#21926)airflow dag
subcommands (#21793)py
DAG files are zipped during parsing (#21538)run_id
(#20975)get_connection()
(#21162)worker_enable_remote_control
for celery (#21507)CgroupTaskRunner
(#21481)SchedulerJob
(#21181)airflow
by 6x (#21438)template_fields
(#21054)ShortCircuitOperator
push XCom by returning python_callable result (#20071)Connection.get_hook
parameter to make it the same as in SqlSensor
and SqlOperator
. (#19849)XCOM
value in PythonOperator (#19378)hook_params
in BaseSqlOperator
(#18718)taskinstance
REST API schema to include dag_run_id field (#19105)extra
to be nullable in connection payload as per schema(REST API). (#23183)dag_id
extraction for dag level access checks in web ui (#23015)CLI
command (#22688)db reset
(#22990)external_task_ids
. (#22809)DagParam
to hold falsy values (#22964)get_logs_with_metadata endpoint
. (#22898)PoolSlotsAvailableDep
statues (#22807)email_on_failure
with render_template_as_native_obj
(#22770)DagFileProcessorManager
(#22685)ScheduleInterval
spec (#22635)is_smart_sensor_compatible()
(#22386)run_id
k8s and elasticsearch compatibility with Airflow 2.1 (#22385)except_skip
None on BranchPythonOperator
(#20411)RefreshConfiguration
workaround for K8s token refreshing (#20759)/connections/<connection>
endpoint (#22227)queued_dttm
when submitting task to directly to executor (#22259)bulk_write_to_db
(#21757)request.referrer
from views.py (#21751)DbApiHook
use get_uri
from Connection (#21764)dag_id
, task_id
etc to XCom.serialize_value
(#19505)on_task_instance_running
listener can get at task (#21157)@task_group
(#20870)airflow trigger
cli (#20781)@task_group
as a whole (#20671)start_date
if a task continues after deferral (#20062)execution_date
label when get cleanup pods list (#20417)class_permission_name
to mixin so it applies to all classes (#18749)catchup=False
is used in example dags (#19396)towncrier
now (#22003)rbac = True
from docs (#22725)sql_alchemy_connect_args
(#22045)db upgrade
/ db downgrade
(#21879)postgres://
with postgresql://
(#21205)CeleryExecutor
docs (#20783)DummyOperator
with EmptyOperator
(#22974)DummyOperator
in favor of EmptyOperator
(#22832)moment
from 2.29.1 to 2.29.2 in /airflow/www (#22873)prismjs
from 1.26.0 to 1.27.0 in /airflow/www (#22823)nanoid
from 3.1.23 to 3.3.2 in /airflow/www (#22803)minimist
from 1.2.5 to 1.2.6 in /airflow/www (#22798)Airflow.Base.metadata
in FAB models (#22353)sql_alchemy_conn
if old postgres scheme used (#22333)xcom.dagrun_id
to xcom.dag_run_id
(#21806)conn.extra
(#21816)jsonschema
to 5.0 (#21712)days_ago
(#21653):type
lines now sphinx-autoapi
supports type hints (#20951)DagRun.run_id
instead of execution_date
when updating state of TIs (UI & REST API) (#18724)PodLauncher
to PodManager
(#20576)get_readable_dags
and get_editable_dags
, and get_accessible_dags
. (#19961)__var
and __type
members (#19303)max_tis_per_query
initialisation on SchedulerJob (#19020)init_role()
from API (#18820)Published by ephraimbuddy over 2 years ago
--capacity
parameter (#21753)order_by(TaskInstance.execution_date)
(#21705)default_pool
delete on web ui (#21658)typing-extensions
to be installed with python 3.8+ #21566 (#21567)__eq__
check (#21442)max_active_runs=1
not scheduling runs when min_file_process_interval
is high (#21413)ExternalTaskSensorLink
to handle templated external_dag_id
(#21192)clear_task_instances
sets valid run state (#21116)X-Frame-Options
header to DENY only if X_FRAME_ENABLED
is set to true. (#19491)on_execute_callback
to callbacks docs (#22362)to_delete
to to_cancel
in TriggerRunner (#20658)3.4.5
(#22596)Published by ephraimbuddy over 2 years ago
priorityClassName
(#20794)envFrom
to the Flower deployment (#21401)airflow.cfg
in wait-for-airflow-migrations containers (#20609)2.2.4
as default Airflow version (#21745)Published by jedcunningham over 2 years ago
dag_id
index for job table (#20282)Dag.get_task_instances()
(#20591)/rendered-k8s
view (#21006)airflow dags backfill --reset-dagruns
errors when run twice (#21062)TaskInstance.max_tries
in refresh_from_task
(#21018)airflow dags test <dag_id> <execution_dt>
results in error when run twice (#21031)>=3.3.4
(#20628)5.2.3
(#19703)<1.1
to <1.2
(#20489)DAG.following_schedule()
for TaskInstance.get_template_context()
(#20486)multiple_outputs
inference of dict typing (#19608)params
keyword (#20640)Params
(#20567)default_args
usage in docs (#19803)@task
(#18868)start_date
values from docs (#19607)Published by jedcunningham almost 3 years ago
type
to extra secrets param (#20599)scheme
(#20564)securityContext
(#18249)migration-wait-timeout
(#20069)pod_template_file
defaults (#19690)check-migrations
command for Airflow>=2 (#19676)affinity
, nodeSelector
, and tolerations
(#20641)helm dependency update
step to chart INSTALL (#20702)multiNamespaceMode
docs to also cover KPO (#19879)2.2.3
as default Airflow version (#20450)Published by jedcunningham almost 3 years ago
snowflake-sqlalchemy
v1.2.5 (#20245)importlib.resources
API (#19091)DagProcessorAgent
(#19935)httpx
to <0.20.0 (#20218)alembic
version (#20153)MarkupSafe
(#20113)DagRun
state is valid on assignment (#19898)KubernetesExecutor
should default to template image if used (#19484)None
state (#19487)DagFileProcessor.manage_slas
(#19553)KubernetesExecutor
pods (#19904)base_log_folder
require updating other configs (#19793)KubernetesExecutor
pod template docs (#19686)execution_date
-> run_id
(#19593).output
operator property information in TaskFlow tutorial doc (#19214)@task
(#18868)pod_template_file
examples (#19691)Published by jedcunningham almost 3 years ago
relativedelta
is passed as schedule_interval
(#19418)Params
with set data type (#19267)None
before calling .is_alive()
(#19380)sqlite_default
Connection has been hard-coded to /tmp
, use gettempdir
instead (#19255)schedule_interval
(#19173)execution_date
to check for existing DagRun
for TriggerDagRunOperator
(#18968)PoolSlotsAvailableDep
(#18875)WTForms<3.0
(#19466)catchup=True
(#19528)Published by jedcunningham almost 3 years ago
cleanup
and createuser
jobs (#19263)extraEnvFrom
examples (#19144)2.2.1
(#19326)Published by jedcunningham almost 3 years ago
Swagger2Specification._set_defaults
classmethod (#19065)None
(#19112)catchup=False
behaviour (#19130, #19145)max_active_runs
(#18897)ds
, ts
, etc. back to use logical date (#19088)None
(#19034)backfill
command before loading DAGs if missing args (#18994)task_fail
violating NOT NULL (#18979)SchedulerJob._process_executor_events
(#18975)XCom.delete
error in Airflow 2.2.0 (#18956)Published by kaxil about 3 years ago
cwd
for BashOperator (#17751)RESTARTING
state (#16681)insert_args
for support transfer replace (#15825)default_args
for TaskGroup
(#16557)kinit
options [-f|-F]
and [-a|-A]
(#17816)DaskExecutor
using Dask Worker Resources (#16829, #18720)processor_poll_interval
to scheduler_idle_sleep_time
(#18704)dagrun_conf
(#18655)TaskInstanceModelView
(#18438)Variable.update
method and improving detection of variable key collisions (#18159)TaskInstance
and TaskReschedule
PK from execution_date
to run_id
(#17719)TaskGroup
support in BaseOperator.chain()
(#17456)template_ext
attribute to show it in UI (#17985)robots.txt
and X-Robots-Tag
header (#17946)BranchDayOfWeekOperator
, DayOfWeekSensor
(#17940)none_failed_or_skipped
by none_failed_min_one_success
trigger rule (#17683)[core] store_dag_code
& use DB to get Dag Code (#16342)task_concurrency
to max_active_tis_per_dag
(#17708)execution_date
with run_id
in airflow tasks run command (#16666)worker_log_server_port
option to the logging section (#17621)SubDagOperator
(#17488)template_fields_renderers
(#17321)airflow celery stop
to accept the pid file. (#17278)airflow_local_settings
(#17195)AirflowException
str when BashOperator
fails. (#17151)SQLite
or SequentialExecutor
(#17133)init_containers
defined in pod_override
(#17537)airflow db init/upgrade
migrations and setup in parallel. (#17078)chain()
and cross_downstream()
to support XComArgs
(#16732)serve-logs
and LocalExecutor
(#16644)test_cycle
to check_cycle
(#16617)LocalExecutor
(#16623)DbApiHook
instance attribute (#16521, #17423)dag.sub_dag
with dag.partial_subset
(#16179)AirflowSensorTimeout
as immediate failure without retrying (#12058)action_clear
view (#15980)[core] dag_concurrency
) settings for easier understanding (#16267, #18730)SKIPPED
should not be logged again as SUCCESS
(#14822)start_date
for cleared tasks (#18708)AirflowDateTimePickerWidget
a required field (#18602)retry_exponential_backoff
divide by zero error when retry delay is zero (#17003){{ task.x }}
attributes from within templates (#18516)sys.path
(#18384)dag_tag
rows that are now unused (#8231)wait_for_downstream
dep (#18338)run_finished_callback
for Debug Executor (#17983)XCom.get_one
return full, not abbreviated values (#18274)XCom.set
(#18240)_check_for_stalled_adopted_tasks
method (#18208)StandardTaskRunner
(#17967)self._error_file
(#15947)DateTimeSensor
(#17959)traceback.html
(#17942)DagRunState
enum query for MySQLdb
driver (#17886)utf8mb3_general_ci
collation for MySQL (#17729)TaskInstance
does not work #17535 (#17548)DAG.cli()
(#17105)None
comparison in model_list
template (#16893)cached_property
module (#16710)Decimal
(#16383)dag_id
and empty subdir
(#16513)dag.fileloc
when using the @dag
decorator (#16384)airflow/www/views.py
(#15940)reschedule
state (#17305, #18806)dagbag_size
documentation (#18824)search_path
set up instructions (#17600)AIRFLOW_GID
from Docker images (#18747)sla_miss_callback
section to the documentation (#18305)closer.lua
script for downloading sources (#18179)DAG.is_active
read-only in API (#17667)XCom.clear
for data lifecycle management (#17589)pod_template_file
(#16861)Jed
and TP
(#16671)flask-ouathlib
to flask-oauthlib
in Upgrading docs (#16320)Elasticsearch
(#16275)dag_concurrency
(#16177)default_pool
slots (#15997)KubernetesExecutor
git-sync
pod template file (#15904)render_template_as_native_obj
(#16534)POST
to PATCH
(#16511)BranchPythonOperator
(#18623)boto3
to <1.19
(#18389)airflow.security.kerberos module
(#18258)range(len())
to enumerate
(#18174)main
builds (#18035)tenacity
(#17593)numpy
dependency (#17594)mysql-connector-python
to latest version (#17596)pandas
an optional core dependency (#17575)airflow/utils/db.py
(#17090)click
to 8.x (#16779)dag.clear
method (#16086)DAG_ACTIONS
constant (#16232)_get_all_non_dag_permissions
method (#16317)docutils
to <0.17 until breaking behaviour is fixed (#16133)TaskInstance.log_filepath
attribute (#15217)airflow/www/app.py
(#15956)plyvel
to google provider extra (#15812)find_permission_view_menu
for get_permission
wrapper (#16377)fab_logging_level
to WARNING
(#18783)CeleryKubernetesExecutor
(#18441)Published by kaxil about 3 years ago
extraContainers
for migrateDatabaseJob
(#18379)loadBalancerSourceRanges
in webserver and flower services (#17666)extraContainers
in k8s workers (#17562)podTemplate
to be templated (#17560)labels
on Triggerer (#18299)uid
0
(#17688)loadBalancerSourceRanges
using code-block (#17763)2.1.4
(#18354)Published by kaxil about 3 years ago
DagRun
execution order from queued to running not being properly followed (#18061)max_active_runs
not allowing moving of queued dagruns to running (#17945)LocalTaskJob
causing error (#18119)colorlog
version (6.x is incompatible) (#18099)create_dagrun
overwrite explicit run_id
(#17728)_check_for_stalled_adopted_tasks
method (#18208)DagRunState
enum query for MySQLdb
driver (#17886)connection-types
provider meta-datacloser.lua
script for downloading sources (#18179)Published by kaxil about 3 years ago
sigkill
and have retries and properly handle sigterm
(#16301)default_impersonation
config (#17229)kubernetes cleanup-pods
which fails on invalid label key (#17298)TaskInstance
does not show queued_by_job_id
& external_executor_id
(#17179)SecretsMasker
is not configured (#17101)__init_subclass__
in subclasses of BaseOperator
(#17027)priority_weight
during parsing (#16765)deps` and
task_group`` during DAG Serialization (#16734)AttributeError
: datetime.timezone
object has no attribute name
(#16599)UserModelView
controls. (#17431)secret_key
mis-configured (#17410)execution_date
in task_instance.refresh_from_db
(#16809)LocalTaskJob
during task exit (#16289)SQLAlchemy<1.4
constraint (#16630)dnspython
(#16698)FlaskAppBuilder
3.3.2+ (#17208)LocalExecutor
(#16623)DagFileProcessor
and DagFileProcessorProcess
out of scheduler_job.py
(#16581)Published by kaxil about 3 years ago
krb5.conf
with CeleryExecutor
(#16822)extraContainers
and extraVolumes
in flower (#16515)minReplicaCount
to the Keda worker-kedaautoscaler.yaml
(#16262)pgbouncer
(#16120)extraInitContainers
to scheduler/webserver/workers (#16098)airflowLocalSettings
and webserver.webserverConfig
(#16074)strategy
/updateStrategy
on scheduler (#16069)loadBalancerIP
and annotations
for both Flower and Webserver (#15972)2.1.2
(#17013)2.1.1
for Helm Chart (#16785)KubernetesExecutor
(#16784)podAntiAffinity
for scheduler, webserver, and workers (#16315)2.1.0
(#16273)git-sync
: root
and dest
params (#15955)knownHosts
(#15950)gitsync
init container (#16339)KubernetesExecutor
to CeleryExecutor
(#16242)webserver.base_url
to be templated (#16126)PgBouncer
exporter sidecar (#16099)dags.gitSync.excludeWebserver
from chart values.schema.json
(#16070)gitsync
Clean Up for KubernetesExecutor
(#15925)gitsync
(#15953)multiNamespaceMode
(#17147)podTemplate
(#16859)pod_template_file.yaml
(#16632)scheduler.livenessprobe.periodSeconds
(#16486)extrasecrets
example (#16305)README.md
files (#16244)appVersion
to 2.1.0 in Chart.yaml
(#16337)main
(#16149)1.1.0-rc1
(#16124)Published by kaxil over 3 years ago
CeleryKubernetesExecutor
(#16700)token
(#16474)LocalTaskJob
(#16852)Published by kaxil over 3 years ago
PyPI
(#16594)dag_run.conf
is a dict (#15057)only_active
parameter to /dags endpoint (#14306)filebeat 7
(#14625)passphrase
and private_key
to default sensitive field names (#16392)airflow task run
without --local
/--raw
for KubeExecutor (#16108)log.exception
when there is no exception (#16047)/
(#16018)Published by kaxil over 3 years ago
conf
not importable from airflow rule (#14400)[scheduler] max_threads
to [scheduler] parsing_processes
(#14913)DatabaseVersionCheckRule
check if invalid version is detected (#15122)False
in LegacyUIDeprecated
(#14967)DbApiHook
(#16543)Published by kaxil over 3 years ago
This is the first release of the Official Helm Chart.