• g

    Gaurav kumar

    5 months ago
    How can we pause a task until a specified time and how to resume the same task before the timeout with some external triggers @Chris White
    g
    Jacob Blanco
    +1
    18 replies
    Copy to Clipboard
  • Jars

    Jars

    5 months ago
    Just saw my flows start
  • Chris White

    Chris White

    5 months ago
    Yea it seems our fix has taken some time to have an effect but the good news is that I am seeing late runs begin to get submitted and are now successfully running; we are still investigating though
  • Jacob Blanco

    Jacob Blanco

    5 months ago
    Same here
  • s

    Stephen Lloyd

    5 months ago
    I’m getting this error when using the FivetranSyncTask
    Traceback (most recent call last):
      File "/Users/slloyd/projects/dwbi-orchestration/.venv/lib/python3.8/site-packages/prefect/engine/task_runner.py", line 880, in get_task_run_state
        value = prefect.utilities.executors.run_task_with_timeout(
      File "/Users/slloyd/projects/dwbi-orchestration/.venv/lib/python3.8/site-packages/prefect/utilities/executors.py", line 468, in run_task_with_timeout
        return task.run(*args, **kwargs)  # type: ignore
      File "workable/src/flow.py", line 64, in fivetran_sync
        status = FivetranSyncTask.run(
    TypeError: method() missing 1 required positional argument: 'self'
    creds is passed in from a PrefectSecret task.
    @task
    def fivetran_sync(connector: str, creds: dict) -> dict:
        status = FivetranSyncTask.run(
            api_key=creds['api_key'],
            api_secret=creds['api_secret'],
            connector_id=connector
            )
        return status
    s
    Jacob Blanco
    2 replies
    Copy to Clipboard
  • Chris White

    Chris White

    5 months ago
    Hello everyone! The Cloud API issue should now be resolved, and we took a few extra steps that should prevent it from recurring; I don't have a full post mortem yet but in short this appears to have been caused by an incredibly large burst of logs entering the system that caused cascading effects. We'll be sure to take our learnings here to prevent this from occurring again and my sincere apologies for your disruption in service!! I hope everyone continues to have a good morning, afternoon or evening depending on where you are
    Chris White
    m
    4 replies
    Copy to Clipboard
  • John Muddle

    John Muddle

    5 months ago
    Hi, I just wanted to highlight this issue https://github.com/PrefectHQ/server/issues/357, we've also seen this, so we're sticking to 2022.01.25 for now. Any ideas when this might be addressed?
    John Muddle
    Kevin Kho
    2 replies
    Copy to Clipboard
  • Geert-Jan Van den Bogaerde

    Geert-Jan Van den Bogaerde

    5 months ago
    Hi all, anyone know if there is a way to retrieve the run config parameters, specifically the labels, from within a flow programmatically at flow runtime? Haven't been able to find it in the docs.
    Geert-Jan Van den Bogaerde
    Kevin Kho
    +1
    13 replies
    Copy to Clipboard
  • m

    Mike

    5 months ago
    Hello all. Does anyone have any experience with or resources for using Prefect with GCP serverless? (cloud functions/cloud run) We are currently running a lot of our workflows using GCP serverless (via cloud functions or cloud run); and we have been using pub/sub queues as an orchestration tool to communicate between tasks. The pub/sub 10 minute message acknowledgement limit is starting to become a problem as some our tasks are taking longer than that to complete, so we wish to look into alternative tools.
    m
    Kevin Kho
    4 replies
    Copy to Clipboard
  • Alexander Gorokhov

    Alexander Gorokhov

    5 months ago
    Hello Prefect team, How a prefect cloud enterprise customer can get a technical support with a bug with prefect cloud itself?
    Alexander Gorokhov
    Kevin Kho
    10 replies
    Copy to Clipboard