We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/hipposys-ltd/airflow-mcp'
If you have feedback or need assistance with the MCP directory API, please join our Discord server
from airflow.decorators import dag, task
from pendulum import datetime
from airflow.datasets import Dataset
import time
@dag(
dag_id="transform_sales_aggregator",
max_active_runs=1,
start_date=datetime(2023, 1, 1),
is_paused_upon_creation=False,
catchup=False,
schedule_interval="*/30 * * * *",
)
def dag_test():
@task(outlets=[Dataset("transform_sales_aggregator")])
def end_task():
time.sleep(40)
end_task()
dag_test()