Hello. We see issue with SequentialTaskRunner. Why second task is not waiting for first one?

@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()

Thanks for the report! That looks like a bug/regression — can you open an issue on GitHub?

Sure