diff --git a/src/dagster_dags/definitions.py b/src/dagster_dags/definitions.py index ba0e8c6..ca715b8 100644 --- a/src/dagster_dags/definitions.py +++ b/src/dagster_dags/definitions.py @@ -4,6 +4,7 @@ from dagster_docker import PipesDockerClient from .assets import nwp, pv, sat +from .resources import SheffieldSolarAPIResource nwp_assets = dg.load_assets_from_package_module( package_module=nwp, @@ -28,6 +29,10 @@ resources={ "pipes_subprocess_client": dg.PipesSubprocessClient(), "pipes_docker_client": PipesDockerClient(), + "ss_api": SheffieldSolarAPIResource( + user_id=dg.EnvVar("SS_USER_ID"), + api_key=dg.EnvVar("SS_API_KEY"), + ), }, jobs=[], schedules=[], diff --git a/src/dagster_dags/resources/__init__.py b/src/dagster_dags/resources/__init__.py index e69de29..9df4ed6 100644 --- a/src/dagster_dags/resources/__init__.py +++ b/src/dagster_dags/resources/__init__.py @@ -0,0 +1,2 @@ +from .sheffield_solar_api import SheffieldSolarAPIResource +