Vadym Dytyniak
12/05/2022, 4:06 PM@task()
def copy_file(n: int):
get_run_logger().info('Start file copying')
time.sleep(n)
get_run_logger().info('Completed file copying')
@flow(task_runner=SequentialTaskRunner())
def sample() -> None:
copy_file.map([3, 4])
if __name__ == '__main__':
sample()
Logs:
18:05:29.909 | INFO | Flow run 'devious-aardwolf' - Created task run 'copy_file-6cc8b0a3-0' for task 'copy_file'
18:05:29.910 | INFO | Flow run 'devious-aardwolf' - Executing 'copy_file-6cc8b0a3-0' immediately...
18:05:29.916 | INFO | Flow run 'devious-aardwolf' - Created task run 'copy_file-6cc8b0a3-1' for task 'copy_file'
18:05:29.917 | INFO | Flow run 'devious-aardwolf' - Executing 'copy_file-6cc8b0a3-1' immediately...
18:05:30.468 | INFO | Task run 'copy_file-6cc8b0a3-1' - Start file copying
18:05:30.534 | INFO | Task run 'copy_file-6cc8b0a3-0' - Start file copying
18:05:33.536 | INFO | Task run 'copy_file-6cc8b0a3-0' - Completed file copying
18:05:33.726 | INFO | Task run 'copy_file-6cc8b0a3-0' - Finished in state Completed()
18:05:34.469 | INFO | Task run 'copy_file-6cc8b0a3-1' - Completed file copying
18:05:34.658 | INFO | Task run 'copy_file-6cc8b0a3-1' - Finished in state Completed()
Zanie
12/05/2022, 4:16 PMVadym Dytyniak
12/05/2022, 4:17 PM