diff --git a/analytics/dagster/src/__init__.py b/analytics/dagster/src/__init__.py index 5577505ee..3c25b881e 100644 --- a/analytics/dagster/src/__init__.py +++ b/analytics/dagster/src/__init__.py @@ -1 +1 @@ -from .definitions import defs as defs \ No newline at end of file +from .definitions import defs as defs diff --git a/analytics/dagster/src/assets/hackernews.py b/analytics/dagster/src/assets/hackernews.py index de008a19d..11059a0c1 100644 --- a/analytics/dagster/src/assets/hackernews.py +++ b/analytics/dagster/src/assets/hackernews.py @@ -34,7 +34,9 @@ def topstories(context: AssetExecutionContext) -> MaterializeResult: results = [] for item_id in topstory_ids: - item = requests.get(f"https://hacker-news.firebaseio.com/v0/item/{item_id}.json").json() + item = requests.get( + f"https://hacker-news.firebaseio.com/v0/item/{item_id}.json" + ).json() results.append(item) if len(results) % 20 == 0: @@ -93,4 +95,4 @@ def most_frequent_words(context: AssetExecutionContext) -> MaterializeResult: json.dump(top_words, f) # Attach the Markdown content as metadata to the asset - return MaterializeResult(metadata={"plot": MetadataValue.md(md_content)}) \ No newline at end of file + return MaterializeResult(metadata={"plot": MetadataValue.md(md_content)}) diff --git a/analytics/dagster/src/definitions.py b/analytics/dagster/src/definitions.py index ec2ebeea2..3070b3e35 100644 --- a/analytics/dagster/src/definitions.py +++ b/analytics/dagster/src/definitions.py @@ -13,4 +13,4 @@ defs = Definitions( assets=load_assets_from_package_module(assets), schedules=[daily_refresh_schedule] -) \ No newline at end of file +)