• Josephine Douglas

    Josephine Douglas

    5 months ago
    Hello! I am trying to create a flow that runs a task, sends the data resulting from that task to a secondary flow, waits for the secondary flow to run successfully, then runs another task. [code in thread] The primary and secondary flows are both registered in the same tenant and project but are set to use different images. When I try to run the primary flow, I get this error:
    Failed to load and execute Flow's environment: TypeError("got an unexpected keyword argument 'raise_final_state'")
    What am I doing incorrectly here?
    Josephine Douglas
    Kevin Kho
    7 replies
    Copy to Clipboard
  • s

    Slackbot

    5 months ago
    This message was deleted.
    s
    Kevin Kho
    +1
    6 replies
    Copy to Clipboard
  • Raviraja Ganta

    Raviraja Ganta

    5 months ago
    I am new to Prefect and want to understand couple of things. • I want to run flows in GPU instance. This means that I have to run the prefect agent in GPU. Does this instance needs to be switched on all the time? How can we scale down/up based on the requests? • I want some other system to trigger the flows (backend systems in my org). For that I am thinking to write APIs for all the flows and trigger them when an API is called. If flows are invoked like this, will this still be shown in the UI? • How exactly prefect agent knows what code to run? Does prefect core code needs to be running all the time? • What are some best practices used for building applications using prefect? - I am getting confused regarding how code is managed Thank you for the help provided 🤗
    Raviraja Ganta
    1 replies
    Copy to Clipboard
  • Florian Guily

    Florian Guily

    5 months ago
    Hello guys, quick questions about retries behaviour. I have a terminal mapped task that has retry policy. The retries seem to work well but i'm a bit worried about the logs. The delay between each retries is 10 secondes and for testing purpose, it is a tiny mapping (tried with 6 children tasks) and the flow is launched locally from terminal. So, between each retries, there is time where there is no task to execute so prefect enters in a "waiting" state according to the log (
    Waiting for next available Task run at 2022-04-27T10:00:35.571259+00:00
    ). After a few seconds, a new log message states:
    Beginning Flow run for 'flow_name'
    and i have all of the previous log message of the previous tasks, as if the flow was re-executed. Is it normal ? Is the flow really reexecuted ? When executing this flow from prefect cloud, i don't see those logs so i'm a bit confused.
    Florian Guily
    Anna Geller
    +1
    36 replies
    Copy to Clipboard
  • Praveen Chaudhary

    Praveen Chaudhary

    5 months ago
    i am able to see projects under command prefect get projects
    Praveen Chaudhary
    Anna Geller
    19 replies
    Copy to Clipboard
  • Praveen Chaudhary

    Praveen Chaudhary

    5 months ago
    but now able to see on UI
  • Praveen Chaudhary

    Praveen Chaudhary

    5 months ago
    how to fix that ?
  • Sang Young Noh

    Sang Young Noh

    5 months ago
    Hello, I'm very new here so apologies for the question if it sounds newbie-like - I'm currently reviewing some prefect 1.0 code with mind to refactor into prefect 2.0, and one of the functions for prefect that is currently being used is prefect.core.parameter.DateTimeParameter, which doesnt seem to be supported in prefect 2.0. Is that the correct interpretation? If so, what would be prefect 2.0 alternative for this? Thanks in advance
    Sang Young Noh
    Anna Geller
    52 replies
    Copy to Clipboard
  • b

    Baris Cekic

    5 months ago
    Hello here, I am new to Prefect and run my first flow in my local K8S cluster and use
    KubernetesRun
    . The flow is trying to download the
    py
    file from a local git repo in the same local K8S cluster. But I got an
    SSL_VERIFICATION
    error even though the
    url/host
    for
    git storage
    is
    HTTP
    . Is there anyone having similar issue?
    b
    Anna Geller
    +1
    75 replies
    Copy to Clipboard
  • Vivek Kaushal

    Vivek Kaushal

    5 months ago
    Hello folks, I am trying to run Prefect server on an EC2 instance using the instructions in Prefect Docs and am facing the following error while trying to get it up and running. Has anyone faced a similar issue in hosting Prefect server?
    Could not upgrade the database!
    graphql_1   | Error: HTTPConnectionPool(host='hasura', port=3000): Max retries exceeded with url: /v1/query (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f25746773d0>: Failed to establish a new connection: [Errno 111] Connection refused'))
    apollo_1    | Checking GraphQL service at <http://graphql:4201/health> ...
    towel_1     | {"severity": "ERROR", "name": "prefect-server.Lazarus", "message": "Unexpected error: ValueError([{'extensions': {'path': '$.selectionSet.flow_run', 'code': 'validation-failed'}, 'message': 'field \"flow_run\" not found in type: \\'query_root\\''}])", "exc_info": "Traceback (most recent call last):\n  File \"/prefect-server/src/prefect_server/services/loop_service.py\", line 60, in run\n    await self.run_once()\n  File \"/prefect-server/src/prefect_server/services/towel/lazarus.py\", line 37, in run_once\n    return await self.reschedule_flow_runs()\n  File \"/prefect-server/src/prefect_server/services/towel/lazarus.py\", line 89, in reschedule_flow_runs\n    limit=500,\n  File \"/prefect-server/src/prefect_server/database/orm.py\", line 501, in get\n    as_box=not apply_schema,\n  File \"/prefect-server/src/prefect_server/database/hasura.py\", line 85, in execute\n    as_box=as_box,\n  File \"/prefect-server/src/prefect_server/utilities/graphql.py\", line 84, in execute\n    raise ValueError(result[\"errors\"])\nValueError: [{'extensions': {'path': '$.selectionSet.flow_run', 'code': 'validation-failed'}, 'message': 'field \"flow_run\" not found in type: \\'query_root\\''}]"}
    Vivek Kaushal
    Anna Geller
    11 replies
    Copy to Clipboard