pierrejeambrun commented on code in PR #67900:
URL: https://github.com/apache/airflow/pull/67900#discussion_r3461193164
##########
airflow-core/src/airflow/utils/sqlalchemy.py:
##########
@@ -434,6 +434,9 @@ def with_row_locks(
# Don't use row level locks if the MySQL dialect (Mariadb & MySQL < 8)
does not support it.
if not USE_ROW_LEVEL_LOCKING:
return query
+ # SQLite does not support FOR UPDATE; skip row-level locking.
+ if dialect_name == "sqlite":
+ return query
Review Comment:
That would also make the change in here not necessary.
--
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]
