ashb commented on code in PR #25935:
URL: https://github.com/apache/airflow/pull/25935#discussion_r963747112
##########
airflow/models/dag.py:
##########
@@ -2532,18 +2532,28 @@ def create_dagrun(
@classmethod
@provide_session
- def bulk_sync_to_db(cls, dags: Collection["DAG"], session=NEW_SESSION):
+ def bulk_sync_to_db(
+ cls,
+ dags: Collection["DAG"],
+ processor_subdir: Optional[str] = None,
+ session=NEW_SESSION,
+ ):
"""This method is deprecated in favor of bulk_write_to_db"""
warnings.warn(
"This method is deprecated and will be removed in a future
version. Please use bulk_write_to_db",
RemovedInAirflow3Warning,
stacklevel=2,
)
- return cls.bulk_write_to_db(dags, session)
+ return cls.bulk_write_to_db(dags, processor_subdir, session)
Review Comment:
Don't _need_ to/shouldn't change this method, as it's a deprecated alias.
--
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]
