David Michael Carter
10/06/2023, 3:10 PMredsquare
10/06/2023, 3:32 PMDavid Michael Carter
10/06/2023, 3:47 PMredsquare
10/06/2023, 3:54 PMDavid Michael Carter
10/06/2023, 3:57 PMredsquare
10/06/2023, 4:17 PMEmil Christensen
10/06/2023, 8:04 PMEmil Christensen
10/06/2023, 8:07 PMfrom prefect import flow
from prefect.context import get_run_context
from prefect.concurrency.sync import concurrency
@flow
def my_flow():
with concurrency(get_run_context().flow.name, occupy=1):
...
redsquare
10/06/2023, 8:07 PMEmil Christensen
10/06/2023, 8:08 PMFredrik Hoem Grelland
10/09/2023, 2:34 PMEmil Christensen
10/09/2023, 4:31 PMmy-flow/my-deployment
)? I’m not 100% sure I follow. If you could give an example, that would help clarify. There’s a lot of other metadata you can find in the return of get_run_context()
.Fredrik Hoem Grelland
10/10/2023, 6:58 AMFredrik Hoem Grelland
10/10/2023, 7:55 AMFredrik Hoem Grelland
10/16/2023, 3:24 PM