• Guilherme Petris

    Guilherme Petris

    4 months ago
    Hey peeps! I’m currently trying it out some tests here to be ran with prefect cloud. When i’m using the flow.run() in my machine just using a LocalRun and Local storage, everything seems to run fine, but when i try to register the flow and run through the UI i get back the ModuleNotFoundError(“No module name ‘/Users/username’“). I’ve already searched for it’s solution back in the discourse page,(https://discourse.prefect.io/t/when-i-run-my-flow-i-see-an-error-failed-to-load-and-exe[…]derror-no-module-named-users-username-what-is-happening/33) but none of the solutions seems to work, even when i specify the module within the agent. The module that i’m using is in the same folder structure and everything seems to work when running directly from my IDE. Can’t figure it out what’s happening 🤔
    Guilherme Petris
    Anna Geller
    10 replies
    Copy to Clipboard
  • a

    Anurag Bajpai

    4 months ago
    We'd like to integrate Sentry with our Prefect flows as described here. However, the approach that has been taken here has been to have the sentry initialisation done in a separate task that is called at the beginning of each flow. Am i correct in believing that this will only work for LocalExecutor and not for LocalDaskExecutor or DaskExecutor? If so, what would be the best practice to have the sentry initialisation done for those executors? Calling the initialisation as a function at the beginning of each task is technically feasible but clunky. Would a Task subclass help here? Could the initialisation be put in a task state handler?
    a
    Anna Geller
    +2
    10 replies
    Copy to Clipboard
  • Naga Sravika Bodapati

    Naga Sravika Bodapati

    4 months ago
    Seeing this error: can't pickle CompiledFFI objects , can someone help what might be the issue?
    Naga Sravika Bodapati
    Anna Geller
    +1
    23 replies
    Copy to Clipboard
  • Jessica Smith

    Jessica Smith

    4 months ago
    can GraphQl be used to invite users to your tenant?
    Jessica Smith
    Kevin Kho
    3 replies
    Copy to Clipboard
  • John Kang

    John Kang

    4 months ago
    Hi all, totally random question but are there any books written about Prefect? I know some popular (like pytest) python libraries have books written on them. Not sure if Prefect had one or not.
    John Kang
    Kevin Kho
    +1
    7 replies
    Copy to Clipboard
  • j

    Jason

    4 months ago
    Morning! When I raise a
    RETRY
    , is it possible to queue an upstream task that had already passed? For example:
    drop_glue_database = Parameter()
    case(drop_glue_database, True):
        drop_stuff()
    
    save_to_parquet()
    If save to parquet fails, I'd like the task to drop and rebuild the database, which is usually unnecessary and parameterized.
    j
    Kevin Kho
    2 replies
    Copy to Clipboard
  • JK

    JK

    4 months ago
    Hello, have been seeing this problem intermittently, any ideas? Prefect endpoint returning 500?
    prefect.exceptions.ClientError: [{'path': ['secret_value'], 'message': 'No value found for the requested key ("xxx") in tenant xxx', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]
    JK
    Kevin Kho
    8 replies
    Copy to Clipboard
  • Andrew Lawlor

    Andrew Lawlor

    4 months ago
    how do i set/access environment variables with a dask executor? i had been setting them with my runconfig, but when i switched to a dask executor they arent showing up anymore
    Andrew Lawlor
    Kevin Kho
    7 replies
    Copy to Clipboard
  • Taras Svirskyi

    Taras Svirskyi

    4 months ago
    Hi, Could you please help with configuring DockerFlowRunner to access flows from GCP storage? I’m following Perfect 2.0 tutorial. I configured GCP storage and successfully used it with “universal runner” for non-dockerised flows. But when I try to run flow deployed with a DockerRunner it fails with the following error cause it couldn’t access the GCP(exception is in the thread). I’m using default user authentification for GCP. Setting
    GOOGLE_APPLICATION_CREDENTIALS
    env var to point to a default location (
    /Users/test/.config/gcloud/application_default_credentials.json
    ) before running an agent didn’t help.
    Taras Svirskyi
    Kevin Kho
    14 replies
    Copy to Clipboard
  • Muhammad Daniyal

    Muhammad Daniyal

    4 months ago
    can we run workflow inside workflow, like
    def workflow1():
       @task
       def abc(): somelogichere
    
       with Flow('one') as f:
          abc()
       
       f.run()
    
    @task
    def xyz(): workflow1()
    
    with Flow('main flow') as f:
       xyz()
    
    f.run()
    Muhammad Daniyal
    j
    2 replies
    Copy to Clipboard