[dagster-powerbi] Fix refreshing semantic models on non-personal work…

…spaces (#25143) ## Summary When testing this feature locally against a live PowerBI instance, I ended up using a non-group scoped URL for my personal workspace. These URLs do not work for group-scoped objects. ## How I Tested These Changes Update unit test, test against live instance.
dagster-io · Oct 8, 2024 · ae09895 · ae09895
1 parent 34d9560
commit ae09895
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/python_modules/libraries/dagster-powerbi/dagster_powerbi/resource.py b/python_modules/libraries/dagster-powerbi/dagster_powerbi/resource.py
@@ -158,7 +158,7 @@ def trigger_refresh(self, dataset_id: str) -> None:
             method="POST",
             endpoint=f"datasets/{dataset_id}/refreshes",
             json={"notifyOption": "NoNotification"},
-            group_scoped=False,
+            group_scoped=True,
         )
         if response.status_code != 202:
             raise Failure(f"Refresh failed to start: {response.content}")
@@ -175,7 +175,7 @@ def poll_refresh(self, dataset_id: str) -> None:
 
             last_refresh = self._fetch_json(
                 f"datasets/{dataset_id}/refreshes",
-                group_scoped=False,
+                group_scoped=True,
             )["value"][0]
             status = last_refresh["status"]
 

diff --git a/python_modules/libraries/dagster-powerbi/dagster_powerbi_tests/test_asset_specs.py b/python_modules/libraries/dagster-powerbi/dagster_powerbi_tests/test_asset_specs.py
@@ -129,20 +129,20 @@ def test_refreshable_semantic_model(
 
     workspace_data_api_mocks.add(
         method=responses.POST,
-        url=f"{BASE_API_URL}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
+        url=f"{BASE_API_URL}/groups/{workspace_id}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
         json={"notifyOption": "NoNotification"},
         status=202,
     )
 
     workspace_data_api_mocks.add(
         method=responses.GET,
-        url=f"{BASE_API_URL}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
+        url=f"{BASE_API_URL}/groups/{workspace_id}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
         json={"value": [{"status": "Unknown"}]},
         status=200,
     )
     workspace_data_api_mocks.add(
         method=responses.GET,
-        url=f"{BASE_API_URL}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
+        url=f"{BASE_API_URL}/groups/{workspace_id}/datasets/{SAMPLE_SEMANTIC_MODEL['id']}/refreshes",
         json={
             "value": [{"status": "Completed" if success else "Failed", "serviceExceptionJson": {}}]
         },