GitHub user Narendra-Neerukonda added a comment to the discussion:
bulk_sync_to_db got UnicodeDecodeError when Chinese characters in dag code
In Airflow 2.1.3, there is an option in core for store_dag_code, which if set
to True, stores the dag code in DB and UI retrieves it from there (below
snippet from 2.1.3):
def code(cls, fileloc) -> str:
if STORE_DAG_CODE:
return cls._get_code_from_db(fileloc)
else:
return cls._get_code_from_file(fileloc)
However, in the current main branch, the store_dag_code option seems to have
been removed and the code is loaded directly from DB (below snippet from main).
So, not sure if the issue will come any more, in future releases.
def code(cls, fileloc) -> str:
return cls._get_code_from_db(fileloc)
GitHub link:
https://github.com/apache/airflow/discussions/63175#discussioncomment-16050771
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
