• m

    mithalee mohapatra

    1 year ago
    Does flow.run() needs a local prefect agent ?
    m
    Jenny
    4 replies
    Copy to Clipboard
  • h

    Hui Zheng

    1 year ago
    Hello everyone. Is there a way to customize the final message of the flow ? Currently it only says
    ====== final results: <Success: "All reference tasks succeeded.">
    or 
    ====== final results: <Failed: "Some reference tasks failed.">
    We have different types of successes/failures. Currently we could not differentiate them from the flow hook notification message. We would like to set customized messages to different scenarios and react differently. for example
    ====== final results: <Failed: "Task_A failed due to timeout.">
    h
    Michael Adkins
    +1
    12 replies
    Copy to Clipboard
  • Laura Vaida

    Laura Vaida

    1 year ago
    hi folks, what is the best way to pass results from one task to another? making a cache?
    Laura Vaida
    Amanda Wee
    +1
    30 replies
    Copy to Clipboard
  • j

    John Ramirez

    1 year ago
    hey everyone - my cloud account is broken (see pic below). Who should I contact to get the account restored?
    j
    Jim Crist-Harif
    +1
    16 replies
    Copy to Clipboard
  • Laura Vaida

    Laura Vaida

    1 year ago
    how to store the gcp credentials in the ui? the whole json or certain aspects of that?ß
    Laura Vaida
    m
    4 replies
    Copy to Clipboard
  • b

    Brian Mesick

    1 year ago
    I’m curious if other folks are running into this. Using a KubernetesRun run config and Docker storage for our flows, we almost always need to manually bump the Docker
    image_tag
    to a new version in order for K8s to pick up the new image. Does anyone have a more automated way of doing this? It’s not uncommon for someone to forget to make that change and leads to confusion about what’s running in prod.
    b
    Michael Adkins
    +2
    8 replies
    Copy to Clipboard
  • i

    itay livni

    1 year ago
    Hi - I have a
    flow
    that runs successfully with a
    LocalExecutor
    . However when the
    flow
    is run using
    flow.executor = DaskExecutor()
    the flow returns a
    Failed to deserialize
    error on the final
    task
    .
    [2021-03-03 08:27:24-0600] INFO - prefect.TaskRunner | Task 'new-terms': Finished task run for task with final state: 'Success'
    INFO:prefect.TaskRunner:Task 'new-terms': Finished task run for task with final state: 'Success'
    distributed.protocol.core - CRITICAL - Failed to deserialize
    Traceback (most recent call last):
      File "miniconda3/envs/py38lmap/lib/python3.8/site-packages/distributed/protocol/core.py", line 151, in loads
        value = _deserialize(head, fs, deserializers=deserializers)
      File "miniconda3/envs/py38lmap/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 374, in deserialize
        return loads(header, frames)
      File "/home/ilivni/miniconda3/envs/py38lmap/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 70, in pickle_loads
        return pickle.loads(x, buffers=buffers)
      File "miniconda3/envs/py38lmap/lib/python3.8/site-packages/distributed/protocol/pickle.py", line 75, in loads
        return pickle.loads(x)
      File "miniconda3/envs/py38lmap/lib/python3.8/site-packages/tblib/pickling_support.py", line 26, in unpickle_exception
        inst = func(*args)
    TypeError: __init__() missing 1 required positional argument: 'request'
    The last task is a
    FilterTask
    filter_res = FilterTask()
    res = filter_res(
                keywords,
                task_args={
                    "name": "new-terms"
                    }
                )
    Any suggestions?
    i
    Jim Crist-Harif
    7 replies
    Copy to Clipboard
  • Laura Vaida

    Laura Vaida

    1 year ago
    hi, what is that pointing at?
    Unexpected error: TypeError("'NoneType' object is not subscriptable")
    Laura Vaida
    Michael Adkins
    62 replies
    Copy to Clipboard
  • Sean Talia

    Sean Talia

    1 year ago
    hi all – I'm trying to get an ECS Agent to launch a task that i've preregistered with ECS (and i'm just passing in the
    task_definition_arn
    to the run configs), but I'm currently getting this error:
    An error occurred (InvalidParameterException) when calling the RunTask operation: Override for container named flow is not a container in the TaskDefinition.
    does this mean that my pre-registered task needs to have a container named
    flow
    ?
    Sean Talia
    Jim Crist-Harif
    3 replies
    Copy to Clipboard
  • Daniel Ahn

    Daniel Ahn

    1 year ago
    Hi, here's yet another license question:
    Prefect Core is licensed under the Apache Software License Version 2.0. Please note that Prefect Core includes utilities for running Prefect Server and the Prefect UI, which are themselves licensed under the Prefect Community License.
    • Is there a clearer documentation on what's under PCL vs Apache 2.0?
    Prefect Core includes utilities for running Prefect Server and the Prefect UI
    • are these referring to the CLI wrapper around docker-compose (https://github.com/PrefectHQ/prefect/tree/master/src/prefect/cli)? • in other words, if I write my own docker-compose to deploy Prefect Core in my environment, the entire architecutre should be under Apache 2.0?
    Daniel Ahn
    Chris White
    5 replies
    Copy to Clipboard