• s

    Sven Teresniak

    2 years ago
    https://docs.prefect.io/orchestration/recipes/k8s_dask.html Why is work stealing disabled in your example and whats the purpose of
    $DASK_DISTRIBUTED__SCHEDULER__BLOCKED_HANDLERS
    ?
    s
    j
    5 replies
    Copy to Clipboard
  • s

    Sven Teresniak

    2 years ago
    How can i change a flow run's name. the flow is triggered by a cron scheduler with time information as a parameter (aggregation for hourly-data). i want to tag each run with this parameter. whats the right way to achive this?
    s
    Dylan
    8 replies
    Copy to Clipboard
  • c

    Chris Goddard

    2 years ago
    I may just be missing something but I keep getting a result of None when I try to do something with the result of the DbtShellTask and looking at the source code it looks like the
    run
    method of DbtShellTask doesn't return the result of the superclass's run method.
    c
    Laura Lorenz (she/her)
    3 replies
    Copy to Clipboard
  • s

    Sven Teresniak

    2 years ago
    I want to run a registered flow with
    prefect run serer --name flowname
    but I need to set a parameter for this run. Is this possible?
    s
    Dylan
    11 replies
    Copy to Clipboard
  • l

    Luke Orland

    2 years ago
    I'm attempting to parameterize the name of a secret for a flow. This attempt is not working:
    l
    Dylan
    6 replies
    Copy to Clipboard
  • j

    Jennifer Meng

    2 years ago
    Hello everyone! I try to run a flow with graphql, but failed to pass parameters. Please help! 🙂
    mutation($parameters: JSON!) {create_flow_run(input: { flow_id: "my_flow_id", parameters: $parameters }) {id}}
    {"parameters":{"param1":"my_param1"}}
    
    Argument 'input' has invalid value {flow_id: \"my_flow_id\", parameters: $parameters}.
    j
    Zachary Hughes
    7 replies
    Copy to Clipboard
  • m

    Matt Allen

    2 years ago
    I'm trying to run the prefect ui and apollo in kubernetes, and I've got everything almost working. When I try to register a flow from my local machine I get a 400 from the graphql endpoint, but I can't see any other information about what's going wrong with the request. Is it possible to get some kind of debug or verbose output from flow.register?
    m
    Chris White
    4 replies
    Copy to Clipboard
  • Alfie

    Alfie

    2 years ago
    Hi folks, I want to use a Parameter which is a list and each item is parameter for a task to run. I cannot iterator Parameters in definition of the flow, any suggestions about how to achieve that?
    Alfie
    Jenny
    3 replies
    Copy to Clipboard
  • m

    Mac Gréco Péralte Chéry

    2 years ago
    Hello, everyone i am trying to pause an unpause the schedule of a flow using the setFlowScheduleState mutation as defined in the documentation by using this graphl code:
    mutation {
      setFlowScheduleState(input: { flow_id: "<flow id>", set_active: true }) {
        success
      }
    }
    but i get this error:
    {
      "graphQLErrors": [],
      "networkError": {
        "name": "ServerError",
        "response": {},
        "statusCode": 400,
        "result": {
          "errors": [
            {
              "message": "Cannot query field \"setFlowScheduleState\" on type \"Mutation\". Did you mean \"set_schedule_active\", \"set_flow_run_states\", or \"set_schedule_inactive\"?",
              "locations": [
                {
                  "line": 2,
                  "column": 3
                }
              ],
              "extensions": {
                "code": "GRAPHQL_VALIDATION_FAILED"
              }
            }
          ]
        }
      },
      "message": "Network error: Response not successful: Received status code 400"
    }
    m
    Jenny
    10 replies
    Copy to Clipboard
  • s

    Sumant Agnihotri

    2 years ago
    Hi all, I'm new to Prefect. Can you help me out with this: This is the basic flow:
    def main():
         # list of arguments
         ls = [1,2,3,4]
     
         # start a thread for calculate method for each arg in ls
         for each in ls:
             thread(each)
     
     def thread(arg):
         t = threading.Thread(target=calculate, args=(arg))
         t.start()
     
     def calculate(*args):
         # does time consuming calculations and pushes the result in the db
    I'm running
    calculate
    method in a python thread, so that multiple threads can run the calculations. Issue is, if
    ls
    is too long, I crash the server (maybe due to too many threads). I want to do this using prefect-dask, but I'm not sure how to do it, or where to look for examples. Any help will be much appreciated. Thanks.
    s
    1 replies
    Copy to Clipboard