Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[AIRFLOW-6786] Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor #7407

Closed
wants to merge 162 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
162 commits
Select commit Hold shift + click to select a range
55bcd8c
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
3706a59
Modifying files in accordance with peer review
Feb 18, 2020
3ed7b77
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
7c50651
Fixing Travis CI Linting errors
Mar 11, 2020
89f5764
Fixing Travis CI Linting errors
Mar 11, 2020
0874dc2
Fixed isort issue
Apr 30, 2020
531a56b
produer --> producer
May 5, 2020
0921de0
Added pylint mandated doc strings
May 5, 2020
37d5d1f
Fixing more pylint issues
May 5, 2020
26227a7
Removed unused imports
May 23, 2020
d2a4b22
Added comma in documentation
May 5, 2020
ecb8a31
Modified the templates index file to see the new hooks and sensors
May 7, 2020
f3b1086
Tried to fix docstrings
May 8, 2020
0e5a0ae
Tried to fix docstrings
May 8, 2020
9d379f0
Apply suggestions from code review
kaxil May 9, 2020
206f9d9
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
5885b14
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
192a93d
Removed unused imports
May 23, 2020
c221956
Removed unused imports
May 23, 2020
7fe057e
Added new line to readme to trigger builds
Jun 5, 2020
788892d
added the python 3.8 requirements
Jun 5, 2020
e792bbb
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
8cf49a1
Modifying files in accordance with peer review
Feb 18, 2020
3334ba8
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
e6ff806
Fixing Travis CI Linting errors
Mar 11, 2020
23b9ed1
Fixing Travis CI Linting errors
Mar 11, 2020
136dc9b
Fixed isort issue
Apr 30, 2020
8197a59
produer --> producer
May 5, 2020
788586e
Added pylint mandated doc strings
May 5, 2020
10531c0
Fixing more pylint issues
May 5, 2020
ba86611
Tried to fix docstrings
May 8, 2020
ad2c460
Tried to fix docstrings
May 8, 2020
0ec3ec7
Apply suggestions from code review
kaxil May 9, 2020
da9daf1
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
8688e6a
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
b600971
Removed unused imports
May 23, 2020
2789458
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
d5673a2
Modifying files in accordance with peer review
Feb 18, 2020
30982c7
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
2847ce0
Fixing Travis CI Linting errors
Mar 11, 2020
4327d3d
Fixing Travis CI Linting errors
Mar 11, 2020
b858e8b
Fixed isort issue
Apr 30, 2020
deba782
produer --> producer
May 5, 2020
5c5c393
Added pylint mandated doc strings
May 5, 2020
8a70321
Fixing more pylint issues
May 5, 2020
f71fa38
Removed unused imports
May 23, 2020
b16b402
Tried to fix docstrings
May 8, 2020
b472e93
Tried to fix docstrings
May 8, 2020
b8239d7
Apply suggestions from code review
kaxil May 9, 2020
57d08d7
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
4ccf498
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
e02d4cc
Removed unused imports
May 23, 2020
b79063f
adding more weird local files
Jun 5, 2020
1e3ced9
Modifying readme to trigger builds
Jun 5, 2020
4bb1da6
Revert "Resolved conflicts in requirements files"
Jun 5, 2020
169779f
Updated readme to trigger build
Jun 5, 2020
374343f
updating requirements files
Jun 5, 2020
a87b26e
updated requirements
Jun 5, 2020
5348178
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
2808b6a
Modifying files in accordance with peer review
Feb 18, 2020
df9aa30
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
163b9cf
produer --> producer
May 5, 2020
4a11c4a
Added pylint mandated doc strings
May 5, 2020
2c16224
Fixing more pylint issues
May 5, 2020
9c0ca5d
Tried to fix docstrings
May 8, 2020
f06049f
Tried to fix docstrings
May 8, 2020
646bcf0
Apply suggestions from code review
kaxil May 9, 2020
0193e67
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
c092186
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
62b4e5a
Removed unused imports
May 23, 2020
c8f2995
updating requirements again
Jun 5, 2020
857f44e
Fixed yaml linting issues
Jun 6, 2020
5974f63
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
d4cbb29
Modifying files in accordance with peer review
Feb 18, 2020
bae395f
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
7976053
Fixing Travis CI Linting errors
Mar 11, 2020
212491d
Fixing Travis CI Linting errors
Mar 11, 2020
53b5f97
produer --> producer
May 5, 2020
6813f27
Added pylint mandated doc strings
May 5, 2020
15e81a0
Fixing more pylint issues
May 5, 2020
29d333d
Tried to fix docstrings
May 8, 2020
93015ef
Tried to fix docstrings
May 8, 2020
28960e8
Apply suggestions from code review
kaxil May 9, 2020
605195e
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
a6a2f74
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
556425a
Removed unused imports
May 23, 2020
3f096dc
Removed unused imports
May 23, 2020
48b7f9f
Updated the requirements files to contain the kafka dependencies
Jun 5, 2020
de2ad60
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
9d9e41f
Modifying files in accordance with peer review
Feb 18, 2020
58b7239
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
fb4e654
Fixing Travis CI Linting errors
Mar 11, 2020
677e23f
Fixed isort issue
Apr 30, 2020
4972f30
produer --> producer
May 5, 2020
06cae89
Added pylint mandated doc strings
May 5, 2020
6c5a96e
Fixing more pylint issues
May 5, 2020
d8f1106
Tried to fix docstrings
May 8, 2020
c0275db
Tried to fix docstrings
May 8, 2020
9de53ae
Apply suggestions from code review
kaxil May 9, 2020
080c3b7
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
3448223
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
40bfe9e
Removed unused imports
May 23, 2020
c4c6e14
Modifying readme to trigger builds
Jun 5, 2020
6d018f4
Revert "Resolved conflicts in requirements files"
Jun 5, 2020
d632949
Updated readme to trigger build
Jun 5, 2020
7a40db4
updating requirements files
Jun 5, 2020
e933030
updated requirements
Jun 5, 2020
0623f7a
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
707b257
Modifying files in accordance with peer review
Feb 18, 2020
45229af
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
7e54375
produer --> producer
May 5, 2020
a01f28c
Added pylint mandated doc strings
May 5, 2020
4a7fbd2
Fixing more pylint issues
May 5, 2020
4eea9ad
Tried to fix docstrings
May 8, 2020
569fa3b
Tried to fix docstrings
May 8, 2020
0676415
Apply suggestions from code review
kaxil May 9, 2020
359666c
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
307dce5
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
f036ee6
Removed unused imports
May 23, 2020
b82cd1a
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
947a3c5
Modifying files in accordance with peer review
Feb 18, 2020
4eaf3ee
Moved files to providers package. Externalized connection logic from…
Mar 2, 2020
b2928a5
Fixing Travis CI Linting errors
Mar 11, 2020
35f0726
Fixing Travis CI Linting errors
Mar 11, 2020
81d086d
produer --> producer
May 5, 2020
8f33a4e
Added pylint mandated doc strings
May 5, 2020
0f5c5c2
Fixing more pylint issues
May 5, 2020
de9e68f
Tried to fix docstrings
May 8, 2020
538880e
Tried to fix docstrings
May 8, 2020
5c6ae5b
Apply suggestions from code review
kaxil May 9, 2020
baf46c2
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
fa27127
Update airflow/providers/apache/kafka/sensors/kafka_sensor.py
dferguson992 May 12, 2020
c95686c
Removed unused imports
May 23, 2020
c0463b2
Removed unused imports
May 23, 2020
8f9a560
added the python 3.8 requirements
Jun 5, 2020
edb2a4e
updating dependencies files
Jun 5, 2020
35b548d
updating requirements again
Jun 5, 2020
af69ccc
Fixed yaml linting issues
Jun 6, 2020
3d44718
Modified file perms
Jun 17, 2020
1085084
Modified file perms
Jun 17, 2020
a6d55a4
Updated requirements files again
Jun 17, 2020
b755869
Fixed indentation issue
Jun 17, 2020
8262de2
Removed trailing whitespace
Jun 17, 2020
033cd6c
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
d4af358
Attempted to rebase?
Aug 25, 2020
5dbd736
??
Aug 25, 2020
f5ec571
Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor
Feb 12, 2020
cbfd33d
Modifying files in accordance with peer review
Feb 18, 2020
62f3c57
Removed unused imports
May 23, 2020
b69e5ee
Fixed isort issue
Apr 30, 2020
5924491
adding more weird local files
Jun 5, 2020
7708186
Modifying readme to trigger builds
Jun 5, 2020
6edd921
Updated readme to trigger build
Jun 5, 2020
bf12172
Fixed yaml linting issues
Jun 6, 2020
f2b7f97
Modifying readme to trigger builds
Jun 5, 2020
3a24cc1
Updated readme to trigger build
Jun 5, 2020
a03c992
updating dependencies files
Jun 5, 2020
3e32050
Modified file perms
Jun 17, 2020
f9f1fb8
Removed legacy hook and sensor code
Aug 25, 2020
f26f880
??????
Aug 26, 2020
e245bed
squash! [AIRFLOW-5500] Fix the trigger_dag api in the case of nested …
Aug 31, 2020
15835e9
Trying to get this to work
Aug 31, 2020
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
Empty file modified BREEZE.rst
100644 → 100755
Empty file.
Empty file modified CHANGELOG.txt
100644 → 100755
Empty file.
Empty file modified CI.rst
100644 → 100755
Empty file.
Empty file modified CODE_OF_CONDUCT.md
100644 → 100755
Empty file.
16 changes: 8 additions & 8 deletions CONTRIBUTING.rst
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -433,14 +433,14 @@ This is the full list of those extras:
.. START EXTRAS HERE

all_dbs, amazon, apache.atlas, apache.beam, apache.cassandra, apache.druid, apache.hdfs,
apache.hive, apache.kylin, apache.pinot, apache.webhdfs, async, atlas, aws, azure, cassandra,
celery, cgroups, cloudant, cncf.kubernetes, dask, databricks, datadog, devel, devel_hadoop, doc,
docker, druid, elasticsearch, exasol, facebook, gcp, gcp_api, github_enterprise, google,
google_auth, grpc, hashicorp, hdfs, hive, jdbc, jira, kerberos, kubernetes, ldap, microsoft.azure,
microsoft.mssql, microsoft.winrm, mongo, mssql, mysql, odbc, oracle, pagerduty, papermill, password,
pinot, postgres, presto, qds, rabbitmq, redis, salesforce, samba, segment, sendgrid, sentry,
singularity, slack, snowflake, spark, ssh, statsd, tableau, vertica, virtualenv, webhdfs, winrm,
yandexcloud, all, devel_ci
apache.hive, apache.kafka, apache.kylin, apache.pinot, apache.webhdfs, async, atlas, aws, azure,
cassandra, celery, cgroups, cloudant, cncf.kubernetes, dask, databricks, datadog, devel,
devel_hadoop, doc, docker, druid, elasticsearch, exasol, facebook, gcp, gcp_api, github_enterprise,
google, google_auth, grpc, hashicorp, hdfs, hive, jdbc, jira, kerberos, kubernetes, ldap,
microsoft.azure, microsoft.mssql, microsoft.winrm, mongo, mssql, mysql, odbc, oracle, pagerduty,
papermill, password, pinot, postgres, presto, qds, rabbitmq, redis, salesforce, samba, segment,
sendgrid, sentry, singularity, slack, snowflake, spark, ssh, statsd, tableau, vertica, virtualenv,
webhdfs, winrm, yandexcloud, all, devel_ci

.. END EXTRAS HERE

Expand Down
Empty file modified Dockerfile
100644 → 100755
Empty file.
Empty file modified Dockerfile.ci
100644 → 100755
Empty file.
Empty file modified IMAGES.rst
100644 → 100755
Empty file.
16 changes: 8 additions & 8 deletions INSTALL
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -46,14 +46,14 @@ pip install . \
# START EXTRAS HERE

all_dbs, amazon, apache.atlas, apache.beam, apache.cassandra, apache.druid, apache.hdfs,
apache.hive, apache.kylin, apache.pinot, apache.webhdfs, async, atlas, aws, azure, cassandra,
celery, cgroups, cloudant, cncf.kubernetes, dask, databricks, datadog, devel, devel_hadoop, doc,
docker, druid, elasticsearch, exasol, facebook, gcp, gcp_api, github_enterprise, google,
google_auth, grpc, hashicorp, hdfs, hive, jdbc, jira, kerberos, kubernetes, ldap, microsoft.azure,
microsoft.mssql, microsoft.winrm, mongo, mssql, mysql, odbc, oracle, pagerduty, papermill, password,
pinot, postgres, presto, qds, rabbitmq, redis, salesforce, samba, segment, sendgrid, sentry,
singularity, slack, snowflake, spark, ssh, statsd, tableau, vertica, virtualenv, webhdfs, winrm,
yandexcloud, all, devel_ci
apache.hive, apache.kafka, apache.kylin, apache.pinot, apache.webhdfs, async, atlas, aws, azure,
cassandra, celery, cgroups, cloudant, cncf.kubernetes, dask, databricks, datadog, devel,
devel_hadoop, doc, docker, druid, elasticsearch, exasol, facebook, gcp, gcp_api, github_enterprise,
google, google_auth, grpc, hashicorp, hdfs, hive, jdbc, jira, kerberos, kubernetes, ldap,
microsoft.azure, microsoft.mssql, microsoft.winrm, mongo, mssql, mysql, odbc, oracle, pagerduty,
papermill, password, pinot, postgres, presto, qds, rabbitmq, redis, salesforce, samba, segment,
sendgrid, sentry, singularity, slack, snowflake, spark, ssh, statsd, tableau, vertica, virtualenv,
webhdfs, winrm, yandexcloud, all, devel_ci

# END EXTRAS HERE

Expand Down
Empty file modified LICENSE
100644 → 100755
Empty file.
Empty file modified LOCAL_VIRTUALENV.rst
100644 → 100755
Empty file.
Empty file modified MANIFEST.in
100644 → 100755
Empty file.
Empty file modified NOTICE
100644 → 100755
Empty file.
3 changes: 2 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
specific language governing permissions and limitations
under the License.
-->

# Apache Airflow

[![PyPI version](https://badge.fury.io/py/apache-airflow.svg)](https://badge.fury.io/py/apache-airflow)
Expand All @@ -40,7 +41,7 @@ Use Airflow to author workflows as directed acyclic graphs (DAGs) of tasks. The

<!-- START doctoc generated TOC please keep comment here to allow auto update -->
<!-- DON'T EDIT THIS SECTION, INSTEAD RE-RUN doctoc TO UPDATE -->
**Table of contents**


- [Requirements](#requirements)
- [Getting started](#getting-started)
Expand Down
Empty file modified STATIC_CODE_CHECKS.rst
100644 → 100755
Empty file.
Empty file modified TESTING.rst
100644 → 100755
Empty file.
Empty file modified UPDATING.md
100644 → 100755
Empty file.
Empty file modified airflow/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/__main__.py
100644 → 100755
Empty file.
Empty file modified airflow/alembic.ini
100644 → 100755
Empty file.
Empty file modified airflow/api/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/backend/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/backend/basic_auth.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/backend/default.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/backend/deny_all.py
100644 → 100755
Empty file.
Empty file modified airflow/api/auth/backend/kerberos_auth.py
100644 → 100755
Empty file.
Empty file modified airflow/api/client/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/client/api_client.py
100644 → 100755
Empty file.
Empty file modified airflow/api/client/json_client.py
100644 → 100755
Empty file.
Empty file modified airflow/api/client/local_client.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/delete_dag.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_code.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_dag_run_state.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_dag_runs.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_lineage.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_task.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/get_task_instance.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/mark_tasks.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/pool.py
100644 → 100755
Empty file.
Empty file modified airflow/api/common/experimental/trigger_dag.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/config_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/connection_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/dag_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/dag_run_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/dag_source_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/event_log_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/extra_link_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/health_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/import_error_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/log_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/pool_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/task_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/task_instance_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/variable_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/version_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/endpoints/xcom_endpoint.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/exceptions.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/openapi/v1.yaml
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/parameters.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/common_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/config_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/connection_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/dag_run_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/dag_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/dag_source_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/enum_schemas.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/error_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/event_log_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/health_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/log_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/pool_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/task_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/variable_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/version_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/schemas/xcom_schema.py
100644 → 100755
Empty file.
Empty file modified airflow/api_connexion/security.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/cli_parser.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/celery_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/config_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/connection_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/dag_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/db_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/info_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/kerberos_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/legacy_commands.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/plugins_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/pool_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/role_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/rotate_fernet_key_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/scheduler_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/sync_perm_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/task_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/user_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/variable_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/version_command.py
100644 → 100755
Empty file.
Empty file modified airflow/cli/commands/webserver_command.py
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/airflow_local_settings.py
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/config.yml
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/default_airflow.cfg
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/default_celery.py
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/default_test.cfg
100644 → 100755
Empty file.
Empty file modified airflow/config_templates/default_webserver_config.py
100644 → 100755
Empty file.
Empty file modified airflow/configuration.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_athena_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_datasync_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_dynamodb_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_firehose_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_glue_catalog_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_lambda_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_logs_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_sns_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/aws_sqs_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_container_instance_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_container_registry_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_container_volume_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_cosmos_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_data_lake_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/azure_fileshare_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/bigquery_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/cassandra_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/cloudant_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/databricks_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/datadog_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/datastore_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/dingding_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/discord_webhook_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/emr_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/fs_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/ftp_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_api_base_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_bigtable_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_cloud_build_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_compute_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_container_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_dataflow_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_dataproc_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_dlp_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_function_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_kms_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_mlengine_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_natural_language_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_pubsub_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_spanner_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_speech_to_text_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_sql_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_tasks_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_text_to_speech_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_transfer_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_translate_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_video_intelligence_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcp_vision_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gcs_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/gdrive_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/grpc_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/imap_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/jenkins_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/mongo_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/openfaas_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/opsgenie_alert_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/pagerduty_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/pinot_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/qubole_check_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/qubole_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/redis_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/redshift_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/sagemaker_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/salesforce_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/segment_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/sftp_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/slack_webhook_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/snowflake_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/spark_jdbc_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/spark_sql_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/spark_submit_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/sqoop_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/ssh_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/vertica_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/wasb_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/hooks/winrm_hook.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/adls_list_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/adls_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/aws_athena_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/aws_sqs_publish_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/awsbatch_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/azure_container_instances_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/azure_cosmos_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_check_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_get_data.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_table_delete_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_to_bigquery.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/bigquery_to_mysql_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/cassandra_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/databricks_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/dataflow_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/dataproc_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/datastore_export_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/datastore_import_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/dingding_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/discord_webhook_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/docker_swarm_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/druid_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/dynamodb_to_s3.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/ecs_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/emr_add_steps_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/emr_create_job_flow_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/emr_terminate_job_flow_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/file_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/file_to_wasb.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_bigtable_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_cloud_build_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_compute_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_container_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_dlp_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_function_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_natural_language_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_spanner_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_speech_to_text_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_sql_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_tasks_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_text_to_speech_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_transfer_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_translate_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_translate_speech_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_video_intelligence_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcp_vision_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_acl_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_delete_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_download_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_list_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_to_bq.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_to_gcs_transfer_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_to_gdrive_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/gcs_to_s3.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/grpc_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/hive_to_dynamodb.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/imap_attachment_to_s3_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/jenkins_job_trigger_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/jira_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/kubernetes_pod_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/mlengine_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/mongo_to_s3.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/mssql_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/mysql_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/opsgenie_alert_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/oracle_to_azure_data_lake_transfer.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/oracle_to_oracle_transfer.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/postgres_to_gcs_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/pubsub_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/qubole_check_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/qubole_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/redis_publish_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_copy_object_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_delete_objects_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_list_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_to_gcs_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_to_gcs_transfer_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/s3_to_sftp_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_base_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_endpoint_config_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_endpoint_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_model_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_training_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_transform_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sagemaker_tuning_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/segment_track_event_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sftp_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sftp_to_s3_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/slack_webhook_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/snowflake_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sns_publish_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/spark_jdbc_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/spark_sql_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/spark_submit_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sql_to_gcs.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/sqoop_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/ssh_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/vertica_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/vertica_to_hive.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/vertica_to_mysql.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/wasb_delete_blob_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/operators/winrm_operator.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/secrets/__init__.py
100644 → 100755
Empty file.
Empty file modified airflow/contrib/secrets/aws_secrets_manager.py
100644 → 100755
Empty file.
Loading