Formatting

dags_tests/cams_test.py

@@ -1,7 +1,8 @@
-from nwp.assets.cams import fetch_cams_forecast_for_day
+import datetime as dt
 import unittest
 
-import datetime as dt
+from nwp.assets.cams import fetch_cams_forecast_for_day
+
 
 class TestCams(unittest.TestCase):
     def test_cams(self):

nwp/assets/cams/cams.py

@@ -1,8 +1,7 @@
+import datetime as dt
+
 import cdsapi
 import dagster
-import os
-
-import datetime as dt
 
 c = cdsapi.Client()
 
@@ -80,7 +79,6 @@ class CAMSConfig(dagster.Config):
 @dagster.op
 def fetch_cams_forecast_for_day(context: dagster.OpExecutionContext, config: CAMSConfig):
     """Fetch CAMS forecast for a given day."""
-
     date: dt.datetime = dt.datetime.strptime(config.date, "%Y-%m-%d")
 
     if date < dt.datetime(2015, 1, 1):

nwp/jobs.py

@@ -1,19 +1,16 @@
 import datetime as dt
-from nwp.assets.cams import (
-    fetch_cams_forecast_for_day,
-    CAMSConfig
-)
 import json
 from collections.abc import Callable
 from typing import Any
 
 import dagster
 
+from nwp.assets.cams import CAMSConfig, fetch_cams_forecast_for_day
 from nwp.assets.dwd.common import IconConfig
 from nwp.assets.ecmwf.mars import (
     NWPConsumerConfig,
     nwp_consumer_convert_op,
-    nwp_consumer_download_op
+    nwp_consumer_download_op,
 )
 
 jobs: list[dagster.JobDefinition] = []