scaffold other code locations

apps/stocks/src/definitions.py

@@ -0,0 +1,27 @@
+import os
+
+import assets
+from dagster_polars import PolarsParquetIOManager
+from icecream import install
+
+import dagster as dg
+from dagster import load_assets_from_modules
+
+install()
+
+APP = os.environ["APP"]
+
+definitions = dg.Definitions(
+    assets=[
+        asset.with_attributes(
+            group_names_by_key={asset.key: APP},
+            tags_by_key={asset.key: {"app": APP}},
+        )
+        for asset in load_assets_from_modules([assets])
+    ],
+    resources={
+        "polars_parquet_io_manager": PolarsParquetIOManager(
+            base_dir=os.environ.get("STORAGE_DIR", "/storage") + f"/{APP}"
+        ),
+    },
+)

apps/tesla/src/definitions.py

@@ -0,0 +1,27 @@
+import os
+
+import assets
+from dagster_polars import PolarsParquetIOManager
+from icecream import install
+
+import dagster as dg
+from dagster import load_assets_from_modules
+
+install()
+
+APP = os.environ["APP"]
+
+definitions = dg.Definitions(
+    assets=[
+        asset.with_attributes(
+            group_names_by_key={asset.key: APP},
+            tags_by_key={asset.key: {"app": APP}},
+        )
+        for asset in load_assets_from_modules([assets])
+    ],
+    resources={
+        "polars_parquet_io_manager": PolarsParquetIOManager(
+            base_dir=os.environ.get("STORAGE_DIR", "/storage") + f"/{APP}"
+        ),
+    },
+)

apps/vinyl/src/definitions.py

@@ -9,18 +9,20 @@ from utils.email import EmailService
 
 import dagster as dg
 
+APP = os.environ["APP"]
+
 install()
 definitions = dg.Definitions(
     assets=[
         asset.with_attributes(
-            group_names_by_key={asset.key: "vinyl"},
-            tags_by_key={asset.key: {"app": "vinyl"}},
+            group_names_by_key={asset.key: APP},
+            tags_by_key={asset.key: {"app": APP}},
         )
         for asset in dg.load_assets_from_modules([assets])
     ],
     resources={
         "polars_parquet_io_manager": PolarsParquetIOManager(
-            base_dir=os.environ.get("STORAGE_DIR", "/storage") + "/vinyl"
+            base_dir=os.environ.get("STORAGE_DIR", "/storage") + f"/{APP}"
         ),
         "email_service": EmailService(
             smtp_server=dg.EnvVar("SMTP_SERVER"),

apps/weather/src/definitions.py

@@ -0,0 +1,27 @@
+import os
+
+import assets
+from dagster_polars import PolarsParquetIOManager
+from icecream import install
+
+import dagster as dg
+from dagster import load_assets_from_modules
+
+install()
+
+APP = os.environ["APP"]
+
+definitions = dg.Definitions(
+    assets=[
+        asset.with_attributes(
+            group_names_by_key={asset.key: APP},
+            tags_by_key={asset.key: {"app": APP}},
+        )
+        for asset in load_assets_from_modules([assets])
+    ],
+    resources={
+        "polars_parquet_io_manager": PolarsParquetIOManager(
+            base_dir=os.environ.get("STORAGE_DIR", "/storage") + f"/{APP}"
+        ),
+    },
+)