[GitHub] [airflow] mik-laj commented on issue #7477: [AIRFLOW-6857] Bulk sync DAGs

[GitBox <gi...@apache.org>]

mik-laj commented on issue #7477: [AIRFLOW-6857] Bulk sync DAGs
URL: https://github.com/apache/airflow/pull/7477#issuecomment-589709150
 
 
   I have following error, so I have to delete wait_for_update.
   ```
   E       sqlalchemy.exc.NotSupportedError: (psycopg2.errors.FeatureNotSupported) FOR UPDATE cannot be applied to the nullable side of an outer join
   E       
   E       [SQL: SELECT dag.dag_id AS dag_dag_id, dag.root_dag_id AS dag_root_dag_id, dag.is_paused AS dag_is_paused, dag.is_subdag AS dag_is_subdag, dag.is_active AS dag_is_active, dag.last_scheduler_run AS dag_last_scheduler_run, dag.last_pickled AS dag_last_pickled, dag.last_expired AS dag_last_expired, dag.scheduler_lock AS dag_scheduler_lock, dag.pickle_id AS dag_pickle_id, dag.fileloc AS dag_fileloc, dag.owners AS dag_owners, dag.description AS dag_description, dag.default_view AS dag_default_view, dag.schedule_interval AS dag_schedule_interval, dag_tag_1.name AS dag_tag_1_name, dag_tag_1.dag_id AS dag_tag_1_dag_id 
   E       FROM dag LEFT OUTER JOIN dag_tag AS dag_tag_1 ON dag.dag_id = dag_tag_1.dag_id 
   E       WHERE dag.dag_id IN (%(dag_id_1)s, %(dag_id_2)s, %(dag_id_3)s, %(dag_id_4)s, %(dag_id_5)s, %(dag_id_6)s, %(dag_id_7)s, %(dag_id_8)s, %(dag_id_9)s, %(dag_id_10)s, %(dag_id_11)s, %(dag_id_12)s, %(dag_id_13)s, %(dag_id_14)s, %(dag_id_15)s, %(dag_id_16)s, %(dag_id_17)s, %(dag_id_18)s, %(dag_id_19)s, %(dag_id_20)s, %(dag_id_21)s, %(dag_id_22)s, %(dag_id_23)s, %(dag_id_24)s, %(dag_id_25)s, %(dag_id_26)s, %(dag_id_27)s, %(dag_id_28)s, %(dag_id_29)s, %(dag_id_30)s, %(dag_id_31)s, %(dag_id_32)s, %(dag_id_33)s, %(dag_id_34)s, %(dag_id_35)s, %(dag_id_36)s, %(dag_id_37)s, %(dag_id_38)s, %(dag_id_39)s, %(dag_id_40)s, %(dag_id_41)s, %(dag_id_42)s, %(dag_id_43)s, %(dag_id_44)s, %(dag_id_45)s, %(dag_id_46)s, %(dag_id_47)s, %(dag_id_48)s, %(dag_id_49)s, %(dag_id_50)s, %(dag_id_51)s, %(dag_id_52)s) FOR UPDATE]
   E       [parameters: {'dag_id_1': 'test_on_kill', 'dag_id_2': 'example_external_task_marker_child', 'dag_id_3': 'test_utils', 'dag_id_4': 'example_xcom', 'dag_id_5': 'test_mark_success', 'dag_id_6': 'test_localtaskjob_double_trigger', 'dag_id_7': 'test_dagrun_states_deadlock', 'dag_id_8': 'example_branch_dop_operator_v3', 'dag_id_9': 'test_depends_on_past', 'dag_id_10': 'test_dagrun_states_fail', 'dag_id_11': 'impersonation_subdag.test_subdag_operation', 'dag_id_12': 'test_dagrun_states_root_fail', 'dag_id_13': 'clear_subdag_test_dag.daily_job', 'dag_id_14': 'test_dagrun_states_root_fail_unfinished', 'dag_id_15': 'example_passing_params_via_test_command', 'dag_id_16': 'latest_only_with_trigger', 'dag_id_17': 'example_subdag_operator.section-1', 'dag_id_18': 'test_start_date_scheduling', 'dag_id_19': 'test_backfill_pooled_task_dag', 'dag_id_20': 'latest_only', 'dag_id_21': 'test_dagrun_states_root_future', 'dag_id_22': 'test_task_start_date_scheduling', 'dag_id_23': 'example_kubernetes_executor', 'dag_id_24': 'test_latest_runs_1', 'dag_id_25': 'test_task_view_type_check', 'dag_id_26': 'example_trigger_target_dag', 'dag_id_27': 'impersonation_subdag', 'dag_id_28': 'test_default_impersonation', 'dag_id_29': 'test_dag_under_subdir2', 'dag_id_30': 'test_zip_dag', 'dag_id_31': 'test_retry_handling_job', 'dag_id_32': 'test_no_impersonation', 'dag_id_33': 'example_short_circuit_operator', 'dag_id_34': 'example_bash_operator', 'dag_id_35': 'test_run_ignores_all_dependencies', 'dag_id_36': 'test_subdag_operator', 'dag_id_37': 'example_subdag_operator.section-2', 'dag_id_38': 'example_kubernetes_executor_config', 'dag_id_39': 'example_branch_operator', 'dag_id_40': 'test_example_bash_operator', 'dag_id_41': 'example_trigger_controller_dag', 'dag_id_42': 'example_complex', 'dag_id_43': 'example_external_task_marker_parent', 'dag_id_44': 'test_subdag_operator.section-1', 'dag_id_45': 'tutorial', 'dag_id_46': 'example_subdag_operator', 'dag_id_47': 'test_heartbeat_failed_fast', 'dag_id_48': 'example_python_operator', 'dag_id_49': 'example_skip_dag', 'dag_id_50': 'test_impersonation', 'dag_id_51': 'clear_subdag_test_dag', 'dag_id_52': 'test_dagrun_states_success'}]
   ```

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services