Skip to content

Commit

Permalink
change to warning
Browse files Browse the repository at this point in the history
Signed-off-by: Yee Hing Tong <[email protected]>
  • Loading branch information
wild-endeavor committed Feb 22, 2025
1 parent da401fc commit d5be81d
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions flytekit/core/python_function_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -727,7 +727,7 @@ def dispatch_execute(self, ctx: FlyteContext, input_literal_map: LiteralMap) ->
project = current_exec_id.project
domain = current_exec_id.domain
name = current_exec_id.name
logger.info(f"Cleaning up potentially still running tasks for execution {name} in {project}/{domain}")
logger.warning(f"Cleaning up potentially still running tasks for execution {name} in {project}/{domain}")
remote = get_plugin().get_remote(config=None, project=project, domain=domain)
key_filter = ValueIn("execution_tag.key", ["eager-exec"])
value_filter = ValueIn("execution_tag.value", [name])
Expand All @@ -741,12 +741,12 @@ def dispatch_execute(self, ctx: FlyteContext, input_literal_map: LiteralMap) ->
filters=[key_filter, value_filter, phase_filter],
sort_by=most_recent,
)
logger.info(f"Found {len(exec_models)} executions this round for termination")
logger.warning(f"Found {len(exec_models)} executions this round for termination")
if not exec_models:
break
logger.info(exec_models)
logger.warning(exec_models)
for exec_model in exec_models:
logger.info(f"Terminating execution {exec_model.id}, phase {exec_model.closure.phase}")
logger.warning(f"Terminating execution {exec_model.id}, phase {exec_model.closure.phase}")
remote.client.terminate_execution(exec_model.id, f"clean up by parent eager execution {name}")
time.sleep(0.5)

Expand Down

0 comments on commit d5be81d

Please sign in to comment.