Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion flytekit/remote/remote.py
Original file line number Diff line number Diff line change
Expand Up @@ -2623,7 +2623,11 @@ def sync_node_execution(
raise ValueError(f"Missing node from mapping: {node_id}")

# Get the node execution data
node_execution_get_data_response = self.client.get_node_execution_data(execution.id)
try:
node_execution_get_data_response = self.client.get_node_execution_data(execution.id)
except FlyteEntityNotExistException:
logger.warning(f"Skipping node {execution.id.node_id} because node data not found")
return execution

# Calling a launch plan directly case
# If a node ran a launch plan directly (i.e. not through a dynamic task or anything) then
Expand Down
Loading