I’m executing `get_run_logger().info(get_client().read_deployment(FlowRunContext.get().flow_run.depl...

Giacomo Chiarella

04/21/2023, 1:50 PM

I’m executing

get_run_logger().info(get_client().read_deployment(FlowRunContext.get().flow_run.deployment_id).name)

in a flow and I get

getAttributeError: 'coroutine' object has no attribute 'name'

I think this is something related to async coroutines. How can I solve it?

flapili

04/21/2023, 1:51 PM

are you using async keyword ?

flapili

04/21/2023, 1:51 PM

to declare the function

Giacomo Chiarella

04/21/2023, 1:53 PM

it is not in a function. I’ve declared the flow like

Copy code

@flow(name=DAG_NAME, retries=3, retry_delay_seconds=30, description="")
def somename(p1: str):
    get_run_logger().info(get_client().read_deployment(FlowRunContext.get().flow_run.deployment_id).name)

flapili

04/21/2023, 1:53 PM

not sure if read_deployment is sync_compatible

flapili

04/21/2023, 1:56 PM

according to the src there is no usage of sync_compatible

flapili

04/21/2023, 2:00 PM

if you can't use async (due to non-async compatible lib as example) you have to use something like anyio.run, else you juste have to use async syntax

Giacomo Chiarella

04/21/2023, 2:03 PM

I’ve tried this:

Copy code

async def get_deployment_name():
    async with get_client() as client:
        return client.read_deployment(FlowRunContext.get().flow_run.deployment_id).name

@flow(name=DAG_NAME, retries=3, retry_delay_seconds=30, description="")
def somename(lineages: str):
    get_run_logger().info(asyncio.run(get_deployment_name()))

but I get the same error

flapili

04/21/2023, 2:04 PM

client.read_deployment is a coro

flapili

04/21/2023, 2:04 PM

you must await it

Giacomo Chiarella

04/21/2023, 2:04 PM

oh yeah, forgot it

Giacomo Chiarella

04/21/2023, 2:06 PM

as far as you know, is there a way to delete all the flows that have no deployments?

Deceivious

04/21/2023, 2:08 PM

Not from UI. But using API yes

Giacomo Chiarella

04/21/2023, 2:08 PM

I cannot find anything in prefect python package, could you point out?

Deceivious

04/21/2023, 2:09 PM

The

client

should have access to deployments

Giacomo Chiarella

04/21/2023, 2:10 PM

I’m talking about flows

flapili

04/21/2023, 2:10 PM

you can by api but

Deceivious

04/21/2023, 2:10 PM

and flows.

Giacomo Chiarella

04/21/2023, 2:10 PM

if I get flows I do not get any info about attached deployments

flapili

04/21/2023, 2:10 PM

it will be O square complexity

Deceivious

04/21/2023, 2:11 PM

U can get deployments - deployment have attached flows. All flows - deployements.flows.id = not deployed flows

Giacomo Chiarella

04/21/2023, 2:11 PM

I thought there was something more easy

flapili

04/21/2023, 2:11 PM

basically it's a double nested loops

Giacomo Chiarella

04/21/2023, 2:12 PM

the cli has

prefect deployment delete

command but there is not a counterpart in flow command

flapili

04/21/2023, 2:12 PM

btw what's your usecase ?

Deceivious

04/21/2023, 2:13 PM

client.delete_deployment()

Giacomo Chiarella

04/21/2023, 2:13 PM

just cleaning

flapili

04/21/2023, 2:13 PM

then juste delete all flows

flapili

04/21/2023, 2:13 PM

they should be repopulated when deploy will run

Giacomo Chiarella

04/21/2023, 2:13 PM

this means that I should delete all flows and deploy again

flapili

04/21/2023, 2:14 PM

Giacomo Chiarella

04/21/2023, 2:14 PM

and if there are running flows that would not be good solution

Deceivious

04/21/2023, 2:14 PM

If your are running a prefect server, run a single query to generate the infomation directly on the database 😄

flapili

04/21/2023, 2:14 PM

flows =/= flows run

Giacomo Chiarella

04/21/2023, 2:15 PM

can I use some orion api instead of direct db query?

Deceivious

04/21/2023, 2:17 PM

edit: Cant use a single api tofetch flow runs without deployments

Giacomo Chiarella

04/21/2023, 2:18 PM

ok, I will see

Deceivious

04/21/2023, 2:20 PM

client.read_flow_runs(FlowRunFilter=FlowRunFilter(deployment_id={"is_null_":True}))

Deceivious

04/21/2023, 2:20 PM

@Giacomo Chiarella Try this.

Giacomo Chiarella

04/21/2023, 2:21 PM

great! I will definitely try it! Thanks!

Deceivious

04/21/2023, 2:21 PM

Actually use this code and test it before actually putting the values through the deletion process. Use at ur own risk xD

Giacomo Chiarella

04/21/2023, 2:22 PM

ahah yeah no worries. If I remember correctly, orion has an endpoint where you can send queries, right?

flapili

04/21/2023, 2:23 PM

you speak about /docs ?

flapili

04/21/2023, 2:24 PM

a webui

Deceivious

04/21/2023, 2:24 PM

/api

Giacomo Chiarella

04/21/2023, 2:24 PM

it was like an elasticsearch but not elasticsearch. /api gives 404

Deceivious

04/21/2023, 2:30 PM

I vaguely rememeber ES like interface. /api by itself doesnt do anything. Check out valid endpoints on /docs

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.