Nash Taylor
05/20/2022, 10:55 PMpy.typedpy.typedfrom prefect.flows import flow
reveal_type(flow)  # Unknownfrom prefect.flows import flow
reveal_type(flow)  # Overload[(__fn: (**P@flow) -> R@flow, /) -> Flow[P@flow, R@flow], (*, name: str = None, version: str = None, task_runner: BaseTaskRunner = ConcurrentTaskRunner, description: str = None, timeout_seconds: int | float = None, validate_parameters: bool = True) -> (((**P@flow) -> R@flow) -> Flow[P@flow, R@flow]), (__fn: Unknown | None = None, *, name: str = None, version: str = None, task_runner: BaseTaskRunner = ConcurrentTaskRunner, description: str = None, timeout_seconds: int | float = None, validate_parameters: bool = True) -> (Flow[P, R] | (((**P) -> R) -> Flow[P, R]))]@task@flow.result()Zanie
Zanie
Nash Taylor
05/21/2022, 1:13 AMtouch py.typedNash Taylor
05/21/2022, 1:13 AMAlvaro Durán Tovar
05/21/2022, 9:17 AMNash Taylor
05/21/2022, 3:15 PMTask.__call__@taskTask[P, NoReturn]PrefectFuture[None, Sync]@taskNone.result()Nash Taylor
05/21/2022, 3:17 PM@task
def my_task(a: str, b: int) -> float:
     return len(a) + b + 0.5Task[P, T]PrefectFuture[T, Sync]PrefectFuture[float, Sync]my_task("a", 0).result()floatNash Taylor
05/21/2022, 3:18 PM