prefect_flow_github_repo_stats_quickstart.py

1import httpx
2from prefect import flow, task
3
4@task(log_prints=True)
5def get_repo_info(repo_name: str):
6    url = f"https://api.github.com/repos/{repo_name}"
7    response = httpx.get(url)
8    response.raise_for_status()
9    repo_stats = response.json()
10    print(f"{repo_name} repository statistics 🤓:")
11    print(f"Stars 🌟 : {repo_stats['stargazers_count']}")
12    print(f"Forks 🍴 : {repo_stats['forks_count']}")
13
14@flow
15def get_repo_flow(repo_name: str = "PrefectHQ/prefect"):
16    get_repo_info(repo_name)
17
18if __name__ == "__main__":
19    get_repo_flow()