Path	Lines of Code
airflow-core/src/airflow/__init__.py	69
airflow-core/src/airflow/api_fastapi/auth/managers/base_auth_manager.py	245
airflow-core/src/airflow/api_fastapi/auth/tokens.py	371
airflow-core/src/airflow/api_fastapi/common/db/common.py	115
airflow-core/src/airflow/api_fastapi/core_api/security.py	240
airflow-core/src/airflow/api_fastapi/core_api/services/ui/connections.py	187
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/taskinstance.py	185
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/token.py	7
airflow-core/src/airflow/api_fastapi/execution_api/routes/asset_events.py	81
airflow-core/src/airflow/api_fastapi/execution_api/routes/assets.py	38
airflow-core/src/airflow/api_fastapi/execution_api/routes/connections.py	41
airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py	621
airflow-core/src/airflow/api_fastapi/execution_api/routes/variables.py	67
airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py	257
airflow-core/src/airflow/cli/commands/task_command.py	345
airflow-core/src/airflow/dag_processing/collection.py	707
airflow-core/src/airflow/dag_processing/manager.py	788
airflow-core/src/airflow/dag_processing/processor.py	219
airflow-core/src/airflow/datasets/__init__.py	25
airflow-core/src/airflow/datasets/metadata.py	10
airflow-core/src/airflow/exceptions.py	270
airflow-core/src/airflow/executors/base_executor.py	441
airflow-core/src/airflow/executors/local_executor.py	144
airflow-core/src/airflow/executors/workloads.py	91
airflow-core/src/airflow/jobs/scheduler_job_runner.py	1793
airflow-core/src/airflow/jobs/triggerer_job_runner.py	670
airflow-core/src/airflow/migrations/versions/0017_2_9_2_fix_inconsistency_between_ORM_and_migration_files.py	138
airflow-core/src/airflow/migrations/versions/0032_3_0_0_rename_execution_date_to_logical_date_and_nullable.py	69
airflow-core/src/airflow/models/baseoperator.py	280
airflow-core/src/airflow/models/connection.py	377
airflow-core/src/airflow/models/dag.py	1757
airflow-core/src/airflow/models/dagrun.py	1394
airflow-core/src/airflow/models/expandinput.py	84
airflow-core/src/airflow/models/taskinstance.py	2452
airflow-core/src/airflow/models/taskmap.py	182
airflow-core/src/airflow/models/variable.py	256
airflow-core/src/airflow/sensors/__init__.py	34
airflow-core/src/airflow/serialization/serialized_objects.py	1517
airflow-core/src/airflow/ui/src/components/ActionAccordion/ActionAccordion.tsx	77
airflow-core/src/airflow/ui/src/pages/Asset/CreateAssetEventModal.tsx	176
airflow-core/src/airflow/ui/src/pages/Dag/Dag.tsx	71
airflow-core/src/airflow/ui/src/pages/Dag/Tasks/TaskCard.tsx	73
airflow-core/src/airflow/ui/src/pages/Run/Details.tsx	135
airflow-core/src/airflow/ui/src/pages/XCom/XComEntry.tsx	36
airflow-core/src/airflow/ui/src/queries/useDagParams.ts	46
airflow-core/src/airflow/ui/src/queries/useLogs.tsx	64
airflow-core/src/airflow/utils/cli.py	268
airflow-core/src/airflow/utils/dag_parsing_context.py	11
airflow-core/src/airflow/utils/db.py	1177
airflow-ctl/pyproject.toml	143
airflow-ctl/src/airflowctl/api/operations.py	336
airflow-ctl/src/airflowctl/ctl/cli_config.py	421
chart/values.yaml	1125
clients/python/openapi_v1.yaml	5353
dev/breeze/src/airflow_breeze/global_constants.py	573
dev/breeze/src/airflow_breeze/utils/selective_checks.py	1240
dev/stats/get_important_pr_candidates.py	309
devel-common/pyproject.toml	172
performance/src/performance_dags/performance_dag/performance_dag_utils.py	321
providers/amazon/pyproject.toml	216
providers/amazon/src/airflow/providers/amazon/aws/executors/batch/batch_executor.py	334
providers/amazon/src/airflow/providers/amazon/aws/executors/ecs/ecs_executor.py	421
providers/amazon/src/airflow/providers/amazon/aws/hooks/redshift_cluster.py	87
providers/apache/tinkerpop/src/airflow/providers/apache/tinkerpop/operators/gremlin.py	22
providers/arangodb/src/airflow/providers/arangodb/operators/arangodb.py	97
providers/arangodb/src/airflow/providers/arangodb/sensors/arangodb.py	24
providers/asana/src/airflow/providers/asana/operators/asana_tasks.py	75
providers/celery/src/airflow/providers/celery/executors/celery_executor.py	347
providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py	260
providers/celery/src/airflow/providers/celery/executors/celery_kubernetes_executor.py	197
providers/celery/src/airflow/providers/celery/sensors/celery_queue.py	34
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py	572
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/local_kubernetes_executor.py	168
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py	962
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py	219
providers/cohere/src/airflow/providers/cohere/operators/embedding.py	42
providers/common/io/src/airflow/providers/common/io/xcom/backend.py	107
providers/common/sql/src/airflow/providers/common/sql/hooks/sql.py	635
providers/common/sql/src/airflow/providers/common/sql/operators/generic_transfer.py	148
providers/common/sql/src/airflow/providers/common/sql/operators/sql.py	803
providers/databricks/src/airflow/providers/databricks/hooks/databricks_base.py	572
providers/databricks/src/airflow/providers/databricks/hooks/databricks_sql.py	213
providers/databricks/src/airflow/providers/databricks/operators/databricks_repos.py	188
providers/databricks/src/airflow/providers/databricks/operators/databricks_sql.py	237
providers/databricks/src/airflow/providers/databricks/sensors/databricks_partition.py	147
providers/databricks/src/airflow/providers/databricks/sensors/databricks_sql.py	81
providers/datadog/src/airflow/providers/datadog/sensors/datadog.py	49
providers/dingding/src/airflow/providers/dingding/operators/dingding.py	35
providers/discord/src/airflow/providers/discord/operators/discord_webhook.py	49
providers/docker/src/airflow/providers/docker/decorators/docker.py	132
providers/docker/src/airflow/providers/docker/operators/docker.py	325
providers/docker/src/airflow/providers/docker/operators/docker_swarm.py	172
providers/edge3/src/airflow/providers/edge3/cli/api_client.py	150
providers/edge3/src/airflow/providers/edge3/cli/edge_command.py	703
providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_json_formatter.py	16
providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py	410
providers/fab/src/airflow/providers/fab/auth_manager/security_manager/override.py	1588
providers/ftp/src/airflow/providers/ftp/sensors/ftp.py	51
providers/github/src/airflow/providers/github/hooks/github.py	43
providers/github/src/airflow/providers/github/operators/github.py	39
providers/github/src/airflow/providers/github/sensors/github.py	88
providers/google/src/airflow/providers/google/cloud/hooks/bigquery.py	1479
providers/google/src/airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py	412
providers/google/src/airflow/providers/google/cloud/hooks/compute_ssh.py	271
providers/google/src/airflow/providers/google/cloud/hooks/datafusion.py	438
providers/google/src/airflow/providers/google/cloud/hooks/gcs.py	905
providers/google/src/airflow/providers/google/cloud/hooks/pubsub.py	399
providers/google/src/airflow/providers/google/cloud/links/dataproc.py	215
providers/google/src/airflow/providers/google/cloud/operators/dataproc.py	1904
providers/google/src/airflow/providers/google/cloud/operators/gcs.py	643
providers/google/src/airflow/providers/google/cloud/sensors/bigquery.py	163
providers/google/src/airflow/providers/google/cloud/sensors/tasks.py	43
providers/google/src/airflow/providers/google/cloud/transfers/gcs_to_gcs.py	272
providers/google/src/airflow/providers/google/cloud/transfers/gcs_to_sftp.py	127
providers/google/src/airflow/providers/google/cloud/utils/external_token_supplier.py	87
providers/google/src/airflow/providers/google/suite/transfers/gcs_to_gdrive.py	89
providers/grpc/src/airflow/providers/grpc/operators/grpc.py	54
providers/http/src/airflow/providers/http/hooks/http.py	325
providers/http/src/airflow/providers/http/operators/http.py	204
providers/http/src/airflow/providers/http/sensors/http.py	99
providers/imap/src/airflow/providers/imap/sensors/imap_attachment.py	37
providers/influxdb/src/airflow/providers/influxdb/operators/influxdb.py	26
providers/jenkins/src/airflow/providers/jenkins/operators/jenkins_job_trigger.py	134
providers/jenkins/src/airflow/providers/jenkins/sensors/jenkins.py	43
providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/msgraph.py	404
providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py	412
providers/microsoft/azure/src/airflow/providers/microsoft/azure/log/wasb_task_handler.py	156
providers/microsoft/azure/src/airflow/providers/microsoft/azure/operators/adx.py	36
providers/microsoft/winrm/src/airflow/providers/microsoft/winrm/hooks/winrm.py	195
providers/microsoft/winrm/src/airflow/providers/microsoft/winrm/operators/winrm.py	66
providers/mongo/src/airflow/providers/mongo/sensors/mongo.py	26
providers/mysql/src/airflow/providers/mysql/transfers/presto_to_mysql.py	46
providers/mysql/src/airflow/providers/mysql/transfers/s3_to_mysql.py	53
providers/mysql/src/airflow/providers/mysql/transfers/trino_to_mysql.py	46
providers/mysql/src/airflow/providers/mysql/transfers/vertica_to_mysql.py	111
providers/neo4j/src/airflow/providers/neo4j/operators/neo4j.py	28
providers/openai/src/airflow/providers/openai/operators/openai.py	95
providers/openlineage/src/airflow/providers/openlineage/extractors/manager.py	257
providers/openlineage/src/airflow/providers/openlineage/utils/utils.py	657
providers/opensearch/src/airflow/providers/opensearch/log/os_json_formatter.py	16
providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py	342
providers/opensearch/src/airflow/providers/opensearch/operators/opensearch.py	122
providers/opsgenie/src/airflow/providers/opsgenie/notifications/opsgenie.py	29
providers/opsgenie/src/airflow/providers/opsgenie/operators/opsgenie.py	138
providers/oracle/src/airflow/providers/oracle/operators/oracle.py	43
providers/oracle/src/airflow/providers/oracle/transfers/oracle_to_oracle.py	53
providers/papermill/src/airflow/providers/papermill/operators/papermill.py	100
providers/pinecone/src/airflow/providers/pinecone/operators/pinecone.py	128
providers/presto/src/airflow/providers/presto/transfers/gcs_to_presto.py	69
providers/qdrant/src/airflow/providers/qdrant/operators/qdrant.py	65
providers/redis/src/airflow/providers/redis/operators/redis_publish.py	22
providers/redis/src/airflow/providers/redis/sensors/redis_key.py	20
providers/redis/src/airflow/providers/redis/sensors/redis_pub_sub.py	32
providers/salesforce/src/airflow/providers/salesforce/operators/bulk.py	74
providers/salesforce/src/airflow/providers/salesforce/operators/salesforce_apex_rest.py	32
providers/samba/src/airflow/providers/samba/transfers/gcs_to_samba.py	109
providers/segment/src/airflow/providers/segment/operators/segment_track_event.py	39
providers/sftp/src/airflow/providers/sftp/hooks/sftp.py	464
providers/sftp/src/airflow/providers/sftp/sensors/sftp.py	130
providers/slack/src/airflow/providers/slack/operators/slack.py	137
providers/slack/src/airflow/providers/slack/operators/slack_webhook.py	67
providers/slack/src/airflow/providers/slack/transfers/sql_to_slack.py	104
providers/slack/src/airflow/providers/slack/transfers/sql_to_slack_webhook.py	73
providers/smtp/src/airflow/providers/smtp/operators/smtp.py	87
providers/snowflake/src/airflow/providers/snowflake/operators/snowflake.py	271
providers/ssh/src/airflow/providers/ssh/operators/ssh.py	120
providers/standard/src/airflow/providers/standard/operators/bash.py	118
providers/standard/src/airflow/providers/standard/operators/datetime.py	68
providers/standard/src/airflow/providers/standard/operators/latest_only.py	68
providers/standard/src/airflow/providers/standard/operators/python.py	681
providers/standard/src/airflow/providers/standard/operators/trigger_dagrun.py	275
providers/standard/src/airflow/providers/standard/operators/weekday.py	38
providers/standard/src/airflow/providers/standard/sensors/bash.py	60
providers/standard/src/airflow/providers/standard/sensors/date_time.py	76
providers/standard/src/airflow/providers/standard/sensors/external_task.py	381
providers/standard/src/airflow/providers/standard/sensors/filesystem.py	97
providers/standard/src/airflow/providers/standard/sensors/python.py	35
providers/standard/src/airflow/providers/standard/sensors/time.py	66
providers/standard/src/airflow/providers/standard/sensors/time_delta.py	93
providers/standard/src/airflow/providers/standard/sensors/weekday.py	42
providers/tableau/src/airflow/providers/tableau/operators/tableau.py	86
providers/tableau/src/airflow/providers/tableau/sensors/tableau.py	36
providers/telegram/src/airflow/providers/telegram/operators/telegram.py	71
providers/teradata/src/airflow/providers/teradata/operators/teradata.py	54
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py	318
providers/teradata/src/airflow/providers/teradata/transfers/s3_to_teradata.py	63
providers/teradata/src/airflow/providers/teradata/transfers/teradata_to_teradata.py	64
providers/trino/src/airflow/providers/trino/transfers/gcs_to_trino.py	69
providers/weaviate/src/airflow/providers/weaviate/operators/weaviate.py	89
providers/yandex/src/airflow/providers/yandex/links/yq.py	24
providers/yandex/src/airflow/providers/yandex/operators/dataproc.py	339
providers/yandex/src/airflow/providers/yandex/operators/yq.py	56
pyproject.toml	1428
scripts/ci/pre_commit/check_base_operator_partial_arguments.py	163
scripts/ci/pre_commit/check_init_decorator_arguments.py	182
scripts/ci/pre_commit/check_template_context_variable_in_sync.py	130
scripts/ci/pre_commit/update_airflow_pyproject_toml.py	143
scripts/ci/pre_commit/validate_operators_init.py	132
task-sdk/src/airflow/sdk/api/client.py	554
task-sdk/src/airflow/sdk/bases/operator.py	1031
task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py	291
task-sdk/src/airflow/sdk/definitions/_internal/contextmanager.py	63
task-sdk/src/airflow/sdk/definitions/_internal/expandinput.py	158
task-sdk/src/airflow/sdk/definitions/_internal/mixins.py	65
task-sdk/src/airflow/sdk/definitions/asset/__init__.py	380
task-sdk/src/airflow/sdk/definitions/asset/decorators.py	152
task-sdk/src/airflow/sdk/definitions/connection.py	98
task-sdk/src/airflow/sdk/definitions/context.py	65
task-sdk/src/airflow/sdk/definitions/dag.py	676
task-sdk/src/airflow/sdk/definitions/decorators/task_group.py	114
task-sdk/src/airflow/sdk/definitions/mappedoperator.py	574
task-sdk/src/airflow/sdk/definitions/taskgroup.py	426
task-sdk/src/airflow/sdk/definitions/variable.py	37
task-sdk/src/airflow/sdk/definitions/xcom_arg.py	365
task-sdk/src/airflow/sdk/execution_time/comms.py	362
task-sdk/src/airflow/sdk/execution_time/context.py	508
task-sdk/src/airflow/sdk/execution_time/execute_workload.py	68
task-sdk/src/airflow/sdk/execution_time/supervisor.py	878
task-sdk/src/airflow/sdk/execution_time/task_runner.py	907
task-sdk/src/airflow/sdk/types.py	93