|
35 | 35 | "target_datetime_utc": [ |
36 | 36 | pd.to_datetime("2025-01-01T00:00:00Z"), |
37 | 37 | pd.to_datetime("2025-01-01T01:00:00Z"), |
38 | | - pd.to_datetime("2025-01-01T00:00:00Z"), |
39 | | - pd.to_datetime("2025-01-01T01:00:00Z"), |
| 38 | + pd.to_datetime("2025-01-01T02:00:00Z"), |
| 39 | + pd.to_datetime("2025-01-01T03:00:00Z"), |
40 | 40 | ], |
41 | 41 | "solar_generation_kw": [5000.0, 6000.0, 2500.0, 3000.0], |
42 | 42 | "region_id": [0, 0, 1, 1], |
@@ -171,16 +171,8 @@ async def test_save_generation_to_data_platform(client, config): |
171 | 171 | energy_source=dp.EnergySource.SOLAR, |
172 | 172 | pivot_timestamp_utc=pivot_time |
173 | 173 | ) |
174 | | - get_location_response = await client.get_location(get_location_request) |
175 | | - |
176 | | - # Retry loop to handle potential eventual consistency in CI |
177 | | - # for i in range(10): |
178 | | - # if get_location_response.effective_capacity_watts == expected_capacity: |
179 | | - # break |
180 | | - # print(f"DEBUG: Retry {i+1}/10 - Capacity mismatch. Got {get_location_response.effective_capacity_watts}, expected {expected_capacity}") |
181 | | - # await asyncio.sleep(1.0) |
182 | | - |
183 | | - assert get_location_response.effective_capacity_watts == 100000000000, \ |
| 174 | + get_location_response = await client.get_location(get_location_request) |
| 175 | + assert get_location_response.effective_capacity_watts == expected_capacity, \ |
184 | 176 | f"Capacity not updated correctly for {location_name}" |
185 | 177 |
|
186 | 178 |
|
|
0 commit comments