Skip to content

Commit

Permalink
real time deck support
Browse files Browse the repository at this point in the history
Signed-off-by: Yicheng-Lu-llll <[email protected]>
  • Loading branch information
Yicheng-Lu-llll committed Jun 22, 2023
1 parent d9829d2 commit 6040dcf
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 4 deletions.
1 change: 0 additions & 1 deletion flytekit/bin/entrypoint.py
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,6 @@ def _dispatch_execute(

ctx.file_access.put_data(ctx.execution_state.engine_dir, output_prefix, is_multipart=True)
logger.info(f"Engine folder written successfully to the output prefix {output_prefix}")
print("entrypoint:", task_def.name.split(".")[-1])
if not task_def.disable_deck:
_output_deck(task_def.name.split(".")[-1], ctx.user_space_params)

Expand Down
3 changes: 0 additions & 3 deletions flytekit/deck/deck.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,9 +75,6 @@ def html(self) -> str:
@classmethod
def persist(self):
task_name = FlyteContextManager.current_context().user_space_params.task_id.name
print("persist:", FlyteContextManager.current_context().user_space_params.task_id)
print("persist:", task_name)
print("persist:", task_name.split(".")[-1])
new_user_params = FlyteContextManager.current_context().user_space_params
_output_deck(task_name , new_user_params)

Expand Down

0 comments on commit 6040dcf

Please sign in to comment.