• o

    Omar Sultan

    1 year ago
    Hi Guys, We're looking to use Webhook Storage to store the flows in our local environment. The Prefect server will be hosted in a K8 Cluster, any recommendations for a storage service that would fit that requirement?
    o
    Kevin Kho
    8 replies
    Copy to Clipboard
  • c

    Camila Solange

    1 year ago
    Hello! when I see the calendar on the board it appears: Reminder! The Prefect Scheduler will only schedule 10 runs in advance. How can I program more scheduling??
    c
    Zach Angell
    3 replies
    Copy to Clipboard
  • Ben Muller

    Ben Muller

    1 year ago
    Hey, I have been trying to delete a project in the UI for half of the day now. Keep getting this error
    Ben Muller
    Zach Angell
    12 replies
    Copy to Clipboard
  • Alireza Taghizadeh

    Alireza Taghizadeh

    1 year ago
    Hi everyone, I am new to prefect, so maybe my question seems naive! is it possible to use @task for methods inside a class? I have a class with several methods that can be set as task.
    Alireza Taghizadeh
    Zach Angell
    2 replies
    Copy to Clipboard
  • Abhishek

    Abhishek

    1 year ago
    Hello folks, i am trying to find a way to give a flow runs a name (currently its generated dynamically in prefect, see screenshot) Is there a way i can configure a flow run name in a code? I don’t see any parameter in
    flow.register()
    I looked into the documentation but couldn’t find it.
    Abhishek
    Greg Roche
    +1
    4 replies
    Copy to Clipboard
  • Konstantin

    Konstantin

    1 year ago
    Hey there! In the Prefect settings, you can use Parameters with the data type 'list', 'dict'. Tell me, what is the maximum number of elements a list and a dictionary in a parameter can contain?
    Konstantin
    Bouke Krom
    +1
    5 replies
    Copy to Clipboard
  • Didier Marin

    Didier Marin

    1 year ago
    Hello there! If there a way to perform a mapping with a specific batch size ? for example lets say I have two tasks
    f
    and g:
    ys = f.map(xs)
    zs = g.map(ys)
    Is there a generic way to give
    g
    batches of y values, for example 10, rather than one at a time ? (And obviously, without having to wait for all the ys to be computed.) Or is this something that is specific to the executor used ?
    Didier Marin
    Zach Angell
    2 replies
    Copy to Clipboard
  • f

    Felipe Saldana

    1 year ago
    Hello Prefect. I have a question about dealing with Flow Parameters. Whats the preferred way to concatenate flow parameters that will be passed into a number of task? Let me type up a simplified example below
    f
    Kevin Kho
    6 replies
    Copy to Clipboard
  • j

    Jacob Hayes

    1 year ago
    Did the "Mapped Tasks" panel go away/move recently?
    j
    Kevin Kho
    9 replies
    Copy to Clipboard
  • b

    Brad I

    1 year ago
    Hi, does anyone know if the env vars set on the prefect agent (deployed in k8s) get injected into a dask cluster automatically? Or do we also have to duplicate them when making the pod spec for dask? Our executor is defined like:
    flow.executor = DaskExecutor(
        cluster_class=lambda: KubeCluster(
            name=f"dask-{flow_image_name}",
            pod_template=make_pod_spec(
                image=prefect.context.image,
                cpu_request=worker_cpu,
                memory_request=worker_mem,
                threads_per_worker=threads_per_worker
            )
        ),
        adapt_kwargs={
            "minimum": min_workers,
            "maximum": max_workers
        },
    )
    b
    Kevin Kho
    6 replies
    Copy to Clipboard