@task
def my_task(a: int):
    wf_params = flytekit.current_context()
    assert (wf_params.execution_id == 'ex:local:local:local')
@task
def my_task(a: int):
    wf_params = flytekit.current_context()
    assert (wf_params.execution_id == 'ex:local:local:local')