kaxil commented on code in PR #61077:
URL: https://github.com/apache/airflow/pull/61077#discussion_r2895842435
##########
airflow-core/tests/unit/cli/commands/test_dag_command.py:
##########
@@ -1070,3 +1071,33 @@ def
test_reserialize_should_support_multiple_bundle_name_arguments(self, configu
serialized_dag_ids =
set(session.execute(select(SerializedDagModel.dag_id)).scalars())
assert serialized_dag_ids == {"test_example_bash_operator",
"test_sensor"}
+
+ @conf_vars({("core", "load_examples"): "false"})
+ def test_reserialize_should_make_equal_hash_with_dag_processor(self,
configure_dag_bundles, session):
+ from airflow.dag_processing.processor import DagFileParsingResult,
DagFileProcessorProcess
+ from airflow.sdk.execution_time.comms import _RequestFrame,
_ResponseFrame
+ from airflow.serialization.serialized_objects import DagSerialization,
LazyDeserializedDAG
Review Comment:
Move Imports at the top of the file please
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
