diff --git a/src/obelisk/asynchronous/producer.py b/src/obelisk/asynchronous/producer.py index b3f5b19..b0ad4f9 100644 --- a/src/obelisk/asynchronous/producer.py +++ b/src/obelisk/asynchronous/producer.py @@ -48,7 +48,7 @@ async def send(self, dataset: str, data: List[dict], response = await self.http_post(f'{self._ingest_url}/{dataset}', data=data, params=params) if response.status_code != 204: - msg = f'An error occured during data ingest. Status {response.status_code}, messasge: {response.text}' + msg = f'An error occured during data ingest. Status {response.status_code}, message: {response.text}' self.log.warning(msg) raise ObeliskError(msg) return response