There was an error while loading. Please reload this page.
1 parent 0663d8e commit a289bcdCopy full SHA for a289bcd
1 file changed
flytekit/remote/remote.py
@@ -2623,7 +2623,11 @@ def sync_node_execution(
2623
raise ValueError(f"Missing node from mapping: {node_id}")
2624
2625
# Get the node execution data
2626
- node_execution_get_data_response = self.client.get_node_execution_data(execution.id)
+ try:
2627
+ node_execution_get_data_response = self.client.get_node_execution_data(execution.id)
2628
+ except FlyteEntityNotExistException:
2629
+ logger.warning(f"Skipping node {execution.id.node_id} because node data not found")
2630
+ return execution
2631
2632
# Calling a launch plan directly case
2633
# If a node ran a launch plan directly (i.e. not through a dynamic task or anything) then
0 commit comments