This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/lang-sdk-e2e/03-native-dag-parse
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 6f91c3ee3e1 Report a native Dag's task that reaches a Python worker
omit 8f7540a4429 Report a Lang-SDK parse past its import timeout as an
import error
omit 8ea7541c6e6 Fill a native Dag's unset settings from the Airflow config
omit caecd20c7ad Parse coordinator-claimed Dag files with their runtime
omit 2b43cb37f72 Move the Dag file processor's shared plumbing into a base
class
omit 395d9cb66a8 Check that a serialized Dag can be stored and loaded
omit 382f2e51300 Let a coordinator parse the Dag files of the bundles it
serves
add cef0df530ff Move the Dag file processor's shared plumbing into a base
class
add d79ced881bf Check that a serialized Dag can be stored and loaded
add e923e5d0aa7 Fill a serialized Dag's unset settings from the Airflow
config
add 66fe7d5fc96 Let a coordinator parse the Dag files of the bundles it
serves
add fa2b6523f71 Parse coordinator-claimed Dag files with their runtime in
the Dag processor
add e07e9050515 Report a Lang-SDK parse past its import timeout as an
import error
add 1610ac78b41 Report a native Dag's task that reaches a Python worker
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 (6f91c3ee3e1)
\
N -- N -- N refs/heads/jason/lang-sdk-e2e/03-native-dag-parse
(1610ac78b41)
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:
.../src/airflow/cli/commands/dag_command.py | 9 +-
airflow-core/src/airflow/dag_processing/dagbag.py | 79 +--
.../src/airflow/dag_processing/processor.py | 3 -
.../src/airflow/serialization/definitions/dag.py | 8 +-
airflow-core/src/airflow/utils/cli.py | 12 +-
.../tests/unit/dag_processing/test_dagbag.py | 191 +-----
.../tests/unit/dag_processing/test_processor.py | 17 -
airflow-core/tests/unit/utils/test_cli_util.py | 56 --
.../src/airflow/sdk/coordinators/_dag_importer.py | 43 +-
task-sdk/src/airflow/sdk/importers/base.py | 3 +-
.../coordinators/fixtures/java_native.json | 151 -----
.../coordinators/fixtures/ts_conformance.json | 661 ---------------------
.../task_sdk/coordinators/test_dag_importer.py | 93 +--
.../tests/task_sdk/importers/test_zip_importer.py | 3 +-
14 files changed, 78 insertions(+), 1251 deletions(-)
delete mode 100644
task-sdk/tests/task_sdk/coordinators/fixtures/java_native.json
delete mode 100644
task-sdk/tests/task_sdk/coordinators/fixtures/ts_conformance.json
