This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch task-sdk-first-code
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 5bb87964752 [skip ci]
omit 3b6cb43adbc make mpypy happy [skip ci]
omit 6efae0f73a0 fix more stest [skip-ci]
omit acdfa2c151b Update pre-commit scripts.
omit e5ebb8a081d Use attrs converters for access_control [skip ci]
omit 5e838d49535 [skip-ci]
omit d8dd35ad9fc Replace DagContext from core to Task SDK [skip ci]
omit f180e2ef474 Use DAG Context from Task SDK [skip ci]
omit 475fa9b33f1 More fixes to test_dagbag.py [skip ci]
omit a6006cbb6a6 [skip ci]
omit 57516144b8b Fix some tests in tests/models/test_dagbag.py [ci skip]
omit 2b11dfa306d [skip ci]
omit af27d4e449b [skip ci]
omit f5669166381 Get more tests passing
omit b45f80cfdde Start porting over all the DAG defintion code to the Task
SDK
add dc25301f35e Remove Scarf analytics from Airflow Webserver (#43346)
add 27f3be666cb Migrate public endpoint Get Airflow Version to FastAPI
(#43312)
add 6070bb6c354 AIP-84 Post Pool (#43317)
add 25ec15c0722 Add Cyberdino to the list of companies using Apache
Airflow (#43345)
add 64336c29b1c Add documentation for the PowerBIDatasetRefresh Operator.
(#42754)
add 7a158493941 Update system test apache-beam[gcp] sdk to the latest
supported version (#43256)
add 98fcc994fbe Move scheduler health unit test to utils folder (#43294)
add 75ecaffa5fa adding support for snippet type in slack api (#43305)
add 218b82576b5 Change prettier config to json (#43353)
add 476e77d9aba Fix spellcheck in main (#43369)
add 7e56dac75cb DatabricksHook: fix status property to work with
ClientResponse used in async mode (#43333)
add 752f9331027 EdgeWorker support log file upload in chunks (#43374)
add 14abd334e88 AIP-84: Add UI batch recent dag runs endpoint (#43204)
add 9e8fb40ba71 Improve the cursor type definition of mysql (#43376)
add 1cc1a2e89d9 Update theme colors in new ui (#43330)
add e05aabe14e7 Start porting over all the DAG defintion code to the Task
SDK
add 247cc60242d Get more tests passing
add dba674c4bf0 [skip ci]
add 9b4f1ad585c [skip ci]
add f40b0086f87 Fix some tests in tests/models/test_dagbag.py [ci skip]
add c1af061bbea [skip ci]
add 92b61614012 More fixes to test_dagbag.py [skip ci]
add 2d004eeaeaa Use DAG Context from Task SDK [skip ci]
add e4aa88756ed Replace DagContext from core to Task SDK [skip ci]
add c041fe19fad [skip-ci]
add 305ade25bef Use attrs converters for access_control [skip ci]
add f6d3744cc72 Update pre-commit scripts.
add f2942be4c51 fix more stest [skip-ci]
add 6555ab7bd73 make mpypy happy [skip ci]
add 2301523b2e6 Fix default pool
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5bb87964752)
\
N -- N -- N refs/heads/task-sdk-first-code (2301523b2e6)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
INTHEWILD.md | 1 +
airflow/api_connexion/endpoints/pool_endpoint.py | 1 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 394 ++++++++++++++++++++-
.../api_fastapi/core_api/routes/public/__init__.py | 2 +
.../api_fastapi/core_api/routes/public/pools.py | 18 +-
.../core_api/routes/public/version.py} | 22 +-
airflow/api_fastapi/core_api/routes/ui/__init__.py | 2 +
airflow/api_fastapi/core_api/routes/ui/dags.py | 133 +++++++
airflow/api_fastapi/core_api/serializers/pools.py | 12 +-
.../core_api/serializers/ui}/__init__.py | 0
.../serializers/{providers.py => ui/dags.py} | 17 +-
.../api_fastapi/core_api/serializers/version.py | 10 +-
airflow/ui/.prettierrc | 13 +
airflow/ui/openapi-gen/queries/common.ts | 67 ++++
airflow/ui/openapi-gen/queries/prefetch.ts | 83 +++++
airflow/ui/openapi-gen/queries/queries.ts | 144 +++++++-
airflow/ui/openapi-gen/queries/suspense.ts | 100 ++++++
airflow/ui/openapi-gen/requests/schemas.gen.ts | 370 ++++++++++++++++++-
airflow/ui/openapi-gen/requests/services.gen.ts | 87 +++++
airflow/ui/openapi-gen/requests/types.gen.ts | 145 +++++++-
airflow/ui/prettier.config.js | 39 --
airflow/ui/src/layouts/Nav/Nav.tsx | 138 ++++----
airflow/ui/src/layouts/Nav/navButtonProps.ts | 6 +
airflow/ui/src/pages/DagsList/DagCard.tsx | 145 ++++----
airflow/ui/src/theme.ts | 23 +-
airflow/utils/usage_data_collection.py | 24 --
airflow/www/templates/airflow/dags.html | 3 -
airflow/www/views.py | 47 +--
.../connections/powerbi.rst | 60 ++++
.../{sensors/msgraph.rst => operators/powerbi.rst} | 28 +-
docs/apache-airflow/faq.rst | 3 -
docs/spelling_wordlist.txt | 1 +
.../providers/databricks/hooks/databricks_base.py | 2 +-
providers/src/airflow/providers/edge/CHANGELOG.rst | 8 +
providers/src/airflow/providers/edge/__init__.py | 2 +-
.../src/airflow/providers/edge/cli/edge_command.py | 18 +-
providers/src/airflow/providers/edge/provider.yaml | 14 +-
.../providers/microsoft/azure/operators/powerbi.py | 4 +
.../providers/microsoft/azure/provider.yaml | 2 +
.../src/airflow/providers/mysql/hooks/mysql.py | 17 +-
.../src/airflow/providers/slack/hooks/slack.py | 8 +-
.../src/airflow/providers/slack/operators/slack.py | 5 +
.../tests/databricks/hooks/test_databricks.py | 14 +
providers/tests/edge/cli/test_edge_command.py | 17 +-
providers/tests/slack/hooks/test_slack.py | 14 +-
providers/tests/slack/operators/test_slack.py | 17 +-
.../tests/system/apache/beam/example_python.py | 10 +-
.../system/apache/beam/example_python_async.py | 10 +-
.../system/apache/beam/example_python_dataflow.py | 2 +-
.../dataflow/example_dataflow_native_python.py | 4 +-
.../example_dataflow_native_python_async.py | 2 +-
.../example_dataflow_sensors_deferrable.py | 2 +-
.../dataflow/example_dataflow_streaming_python.py | 2 +-
.../core_api/routes/public/test_dags.py | 4 +-
.../core_api/routes/public/test_pools.py | 49 +++
.../core_api/routes/public/test_version.py} | 33 +-
tests/api_fastapi/core_api/routes/ui/test_dags.py | 104 ++++++
tests/cli/commands/test_scheduler_command.py | 52 +--
tests/utils/test_scheduler_health.py | 79 +++++
tests/utils/test_usage_data_collection.py | 18 -
tests/www/views/test_views.py | 38 --
tests/www/views/test_views_home.py | 14 -
62 files changed, 2177 insertions(+), 526 deletions(-)
copy airflow/{api_connexion/endpoints/version_endpoint.py =>
api_fastapi/core_api/routes/public/version.py} (73%)
create mode 100644 airflow/api_fastapi/core_api/routes/ui/dags.py
copy airflow/{api_connexion =>
api_fastapi/core_api/serializers/ui}/__init__.py (100%)
copy airflow/api_fastapi/core_api/serializers/{providers.py => ui/dags.py}
(65%)
copy providers/tests/system/google/conftest.py =>
airflow/api_fastapi/core_api/serializers/version.py (83%)
create mode 100644 airflow/ui/.prettierrc
delete mode 100644 airflow/ui/prettier.config.js
create mode 100644
docs/apache-airflow-providers-microsoft-azure/connections/powerbi.rst
copy docs/apache-airflow-providers-microsoft-azure/{sensors/msgraph.rst =>
operators/powerbi.rst} (54%)
copy tests/{api_connexion/endpoints/test_version_endpoint.py =>
api_fastapi/core_api/routes/public/test_version.py} (64%)
create mode 100644 tests/api_fastapi/core_api/routes/ui/test_dags.py
create mode 100644 tests/utils/test_scheduler_health.py
