• m

    Marwan Sarieddine

    7 months ago
    Hi folks, since last week we have been encountering an issue with prefect cloud, version locking and heartbeat failures - more details in the thread.
    m
    Anna Geller
    18 replies
    Copy to Clipboard
  • Aqib Fayyaz

    Aqib Fayyaz

    7 months ago
    Hi, i have kind of silly question, if i want to run agent, flow and server on same gke cluster can i have local agent instead of kubernetes agent?
    Aqib Fayyaz
    Anna Geller
    49 replies
    Copy to Clipboard
  • n

    Nick Hart

    7 months ago
    I'm looking to run create_flow_runs using threading for a custom module I'm writing and for some reason I'm getting an attribute error. Below is my test code and the error. Would you know how to fix this? Also, I'm assuming this is not a prefect problem and more of a threading problem, but I was hoping someone would be able to help! Thanks in advance
    from prefect.tasks.prefect import create_flow_run, wait_for_flow_run
    import threading
    
    def thread_flows(flowname):
        print("Running thread for: ",flowname)
        flow_id = create_flow_run.run(flow_name=flowname)
        flow_run = wait_for_flow_run.run(flow_id, stream_logs=True)#
    
    if __name__ == "__main__":
        flow_list = ["FlowA", "FlowB", "FlowC"]
    
        threads = []
        for flowname in flow_list:
            x = threading.Thread(target = thread_flows, args=(flowname,))
            threads.append(x)
            x.start()
    
        for thread in threads:
            thread.join()
    File "/home/test/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 870, in run
        self._target(*self._args, **self._kwargs)
      File "/home/test/Documents/create-flow1.py", line 6, in thread_flows
        self._target(*self._args, **self._kwargs)
      File "/home/test/Documents/create-flow1.py", line 6, in thread_flows
        flow_id = create_flow_run.run(flow_name=flowname)
      File "/home/test/.pyenv/versions/3.8.6/lib/python3.8/site-packages/prefect/tasks/prefect/flow_run.py", line 123, in create_flow_run
        logger = prefect.context.logger
    AttributeError: 'Context' object has no attribute 'logger'
    n
    Michael Adkins
    +1
    8 replies
    Copy to Clipboard
  • a

    Aaron Rnd

    7 months ago
    Hi guys, i have a question. Is it possible to start another flow, once a task in another flow is completed. For illustration :- Flow A Task 1 > Task 2 > Task 3 Flow B (once Task 2 in Flow A is completed on success, run Flow B) Task 1
    a
    Michael Adkins
    6 replies
    Copy to Clipboard
  • Raimundo Pereira De Souza Neto

    Raimundo Pereira De Souza Neto

    7 months ago
    Hello guys, I'm using
    prefect=2.0a12
    , and I would like to schedule my flow like a cronJob. It's possible with decorator?
    from prefect import flow, task
    
    @task()
    def s1(message):
        print(message)
    
    @flow() # where I put schedule params?
    def update_flow() -> None:
        s1("hello prefect")
    Raimundo Pereira De Souza Neto
    Anna Geller
    2 replies
    Copy to Clipboard
  • Anna Geller

    Anna Geller

    7 months ago
    set the channel topic: Welcome to the Prefect Community! Please use threads if possible so we can archive helpful conversations to:- GitHub: https://github.com/PrefectHQ/prefect/issues?q=label%3A“Prefect+Slack+Community”+ - Discourse: https://discourse.prefect.io/docs
  • Patrick Tan

    Patrick Tan

    7 months ago
    Hi guys, I have flow deployment issue. Agent does not pickup flow registered in different host  Host A1. I was doing my development on my local Macbook: 2. I created a flow  3. I switched backend to prefect cloud 4. I connected to Prefect cloud with API key. 5. I registered flow to to Prefect Cloud. 6. I started local agent  7. I can see both the flow and agent in Prefect Cloud UI 8. I ran the flow, agent picked up and execute the flow, it worked fine 9. I shutdown the agent Host B1. I created AWS EC2 instance and deploy my code 2. I connected to Prefect Cloud with same API key  3. I switched backend to Prefect Cloud and started local agent 4. I can see agent in UI 5. However, when I start running Flow I registered earlier, agent does not pickup flow Please advise
    Patrick Tan
    Kevin Kho
    +2
    9 replies
    Copy to Clipboard
  • Daniel Komisar

    Daniel Komisar

    7 months ago
    Hello everyone, is it possible to add/remove labels from agents through the API with
    update_agent_config
    ? Thanks!
    Daniel Komisar
    Anna Geller
    +1
    5 replies
    Copy to Clipboard
  • s

    shijas km

    7 months ago
    hi a quick question we have created prefect flows in our dev env and using prefect cloud to schedule and run now we need to implement ci/cd to automate deployment to prod env, how can we achieve it we are not using docker for prefect what is the easiest method for ci/cd for prefect
    s
    Michael Adkins
    2 replies
    Copy to Clipboard
  • n

    Noam polak

    7 months ago
    Hey dear community We recently have an issue when we were triggering 3 instances of the same parent flow that triggers a child flows (it's not the common use case but we wanted to test this case also) And we get errors from the prefect-server that goes like this.. - I will write in the thread What can possibly be the cause? Thanks
    n
    Anna Geller
    +1
    11 replies
    Copy to Clipboard