@Marvin what is the correct way to filter flow tuns using the python sdk client where a tag "EXAMPLE" is present

Before I dive into your question, I need to determine the version of Prefect that you're using, since the syntax and methods can differ between 2.x and 3.x. Could you please let me know which version you are using? If you're not sure, I can search the documentation for you.

@Marvin I am using 2.x

To filter flow runs by a specific tag, such as "EXAMPLE," using the Prefect 2.x Python SDK Client, you can make use of the filtering capabilities provided by Prefect's API. Here's a general approach you might follow: 1. Get the Client: First, you'll need to get the client to interact with the Prefect API. 2. Filter Flow Runs: Use the client's methods to filter flow runs based on specific criteria, such as tags. Here's an example of how you might write this code:

python
from prefect import get_client

async def get_flow_runs_with_tag(tag: str):
    async with get_client() as client:
        flow_runs = await client.read_flow_runs(
            filter={"tags": {"all_": [tag]}}
        )
    return flow_runs

# Example usage
import anyio
tag = "EXAMPLE"
anyio.run(get_flow_runs_with_tag, tag)

Make sure you have any necessary asyncio environment set up to work with

async

functions. This query will filter flow runs that include the tag "EXAMPLE." For more details or further configuration, you might want to check out the Prefect 2.x documentation on using the client, which can provide additional examples and context: Prefect 2.x Client Guide. It seems destiny hasn't been kind with a specific filtering example in my quick search, so you might dive into their guides for more hidden gems!

@Marvin is there a way to grab all the flow runs that don't have specific tag?

It seems like there isn't a straightforward example in the Prefect 2.x documentation for filtering out flow runs that specifically do not have a certain tag. However, you can employ a bit of a workaround by retrieving all flow runs and then programmatically filtering them out based on the absence of a tag. Here's a conceptual approach using Python:

python
from prefect import get_client

async def get_flow_runs_without_tag(tag: str):
    async with get_client() as client:
        # Retrieve all flow runs
        flow_runs = await client.read_flow_runs()
        
        # Filter out flow runs with the specific tag
        filtered_flow_runs = [run for run in flow_runs if tag not in run.tags]
    
    return filtered_flow_runs

# Example usage
import anyio
tag = "EXAMPLE"
flow_runs_without_tag = anyio.run(get_flow_runs_without_tag, tag)
print(flow_runs_without_tag)

Please note, this approach can be a bit inefficient if you have a large number of flow runs, as it retrieves all flow runs before filtering them in memory. You might want to check Prefect's documentation or community forums for more scalable solutions if performance becomes a concern. For further tinkering, you might explore the guides: Prefect 2.x Client Guide. Sadly, API calls aren't as cheerful as they should be.