diff --git a/wikibaseintegrator/wbi_helpers.py b/wikibaseintegrator/wbi_helpers.py index 55072ca5..7c1dc191 100644 --- a/wikibaseintegrator/wbi_helpers.py +++ b/wikibaseintegrator/wbi_helpers.py @@ -279,7 +279,7 @@ def execute_sparql_query(query: str, prefix: str | None = None, endpoint: str | if prefix: query = prefix + '\n' + query - params = { + body = { 'query': '#Tool: WikibaseIntegrator wbi_functions.execute_sparql_query\n' + query, 'format': 'json' } @@ -294,11 +294,11 @@ def execute_sparql_query(query: str, prefix: str | None = None, endpoint: str | if headers: request_headers.update(headers) - log.debug("SPARQL query:\n%s", params['query']) + log.debug("SPARQL query:\n%s", body['query']) for _ in range(max_retries): try: - response = helpers_session.post(sparql_endpoint_url, data=params, headers=request_headers, auth=auth, timeout=config['TIMEOUT']) + response = helpers_session.post(sparql_endpoint_url, data=body, headers=request_headers, auth=auth, timeout=config['TIMEOUT']) except requests.exceptions.ConnectionError as e: log.exception("Connection error: %s. Sleeping for %d seconds.", e, retry_after) sleep(retry_after)