nicnguyen3103 commented on issue #52413: URL: https://github.com/apache/airflow/issues/52413#issuecomment-3018390023
> Maybe this is problematic: > > [airflow/airflow-core/src/airflow/dag_processing/processor.py](https://github.com/apache/airflow/blob/e455329ca352b31c866f859dfa3446110166153d/airflow-core/src/airflow/dag_processing/processor.py#L129) > > Line 129 in [e455329](/apache/airflow/commit/e455329ca352b31c866f859dfa3446110166153d) > > def _parse_file(msg: DagFileParseRequest, log: FilteringBoundLogger) -> DagFileParsingResult | None: > ``` > def _parse_file(msg: DagFileParseRequest, log: FilteringBoundLogger) -> DagFileParsingResult | None: > # TODO: Set known_pool names on DagBag! > bag = DagBag( > dag_folder=msg.file, > bundle_path=msg.bundle_path, > include_examples=False, > safe_mode=True, > load_op_links=False, > ) > ``` Confirmed that the force safe_mode is the issue. I have checked the logic in the DagBag parse file, everything function normally -- 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]
