Russell Brooks
03/16/2022, 10:53 PMKevin Kho
Russell Brooks
03/16/2022, 11:48 PMKevin Kho
Russell Brooks
03/17/2022, 12:05 AMKevin Kho
Russell Brooks
03/17/2022, 12:13 AMKevin Kho
Russell Brooks
03/17/2022, 12:25 AMKevin Kho
Russell Brooks
03/17/2022, 12:36 AMKevin Kho
Russell Brooks
03/17/2022, 1:00 AMKevin Kho
Russell Brooks
03/17/2022, 1:47 AMKevin Kho
from prefect import Flow, task
import prefect
from prefect.executors import LocalDaskExecutor
@task
def test(x):
<http://prefect.context.logger.info|prefect.context.logger.info>(f"test-{x}")
return x+1
with Flow("processes") as flow:
test.map([1,2,3,4,5,6,7,8,9,10])
flow.executor = LocalDaskExecutor(scheduler="processes")
flow.register("databricks")
and my logs shows stuffRussell Brooks
03/17/2022, 3:49 AM