Skip to content

Commit f588f60

Browse files
committed
fix for deterministic ordering of v4 api
1 parent a017136 commit f588f60

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

airflow/knesset_data_pipelines/run_pipeline.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -265,9 +265,9 @@ def add_dataservice_collection_resource_odata_v4(params, proxies, stats, limit_r
265265
skip = None
266266
while True:
267267
if skip is None:
268-
url = f'{url_base}?$count=true'
268+
url = f'{url_base}?$orderby=Id&$count=true'
269269
else:
270-
url = f'{url_base}?$skip={skip}'
270+
url = f'{url_base}?$orderby=Id&$skip={skip}'
271271
print(url)
272272
status_code, content = get_response_content(url, params, timeout, proxies)
273273
assert status_code == 200, f'unexpected status code: {status_code} for url {url}\n{content}'

0 commit comments

Comments
 (0)