TJaniF commented on PR #38902:
URL: https://github.com/apache/airflow/pull/38902#issuecomment-2134635772
@rightx2 That is interesting. I just tried that and for me the map index
values from the first run "stick", but maybe I misunderstood what you are doing
:)
This is what I tried:
rightx2 commented on PR #38902:
URL: https://github.com/apache/airflow/pull/38902#issuecomment-2134469117
I wonder what I've experienced is same type of the problem above:
1. clear dynnamic mapped tasks
2. all dynamic mapped tasks go into state of running
3. Force to set dag run
Lee-W merged PR #38902:
URL: https://github.com/apache/airflow/pull/38902
--
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:
RNHTTR commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1562596410
##
airflow/models/taskinstance.py:
##
@@ -2714,18 +2714,29 @@ def signal_handler(signum, frame):
previous_state=TaskInstanceState.QUEUED,
RNHTTR commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1562594872
##
airflow/models/taskinstance.py:
##
@@ -2714,18 +2714,29 @@ def signal_handler(signum, frame):
previous_state=TaskInstanceState.QUEUED,
uranusjr commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1562406985
##
airflow/models/taskinstance.py:
##
@@ -2714,18 +2714,29 @@ def signal_handler(signum, frame):
previous_state=TaskInstanceState.QUEUED,
kaxil commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1562401551
##
airflow/models/taskinstance.py:
##
@@ -2714,18 +2714,29 @@ def signal_handler(signum, frame):
previous_state=TaskInstanceState.QUEUED,
ashb commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1562367870
##
airflow/models/taskinstance.py:
##
@@ -2714,18 +2714,29 @@ def signal_handler(signum, frame):
previous_state=TaskInstanceState.QUEUED,
TJaniF commented on PR #38902:
URL: https://github.com/apache/airflow/pull/38902#issuecomment-2051345427
@uranusjr thank you!
--
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
uranusjr commented on PR #38902:
URL: https://github.com/apache/airflow/pull/38902#issuecomment-2051246536
This should fix thingsā¦
--
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
TJaniF commented on PR #38902:
URL: https://github.com/apache/airflow/pull/38902#issuecomment-2049927602
> Need to fix tests
Sorry silly question but for `breeze testing non-db-tests
--parallel-test-types "Core"` which I think runs my two new tests
I get:
```text
TJaniF commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1560866337
##
airflow/models/taskinstance.py:
##
@@ -2715,29 +2727,26 @@ def signal_handler(signum, frame):
# Execute the task
with
TJaniF commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1560866337
##
airflow/models/taskinstance.py:
##
@@ -2715,29 +2727,26 @@ def signal_handler(signum, frame):
# Execute the task
with
uranusjr commented on code in PR #38902:
URL: https://github.com/apache/airflow/pull/38902#discussion_r1560385357
##
airflow/models/taskinstance.py:
##
@@ -2715,29 +2727,26 @@ def signal_handler(signum, frame):
# Execute the task
with
14 matches
Mail list logo