Is the problem because now each Node is run with different session and you want to have 1 ID for the entire Airflow dag?