diff --git a/src/app.py b/src/app.py
index 1f30975..dd3f174 100644
--- a/src/app.py
+++ b/src/app.py
@@ -40,8 +40,9 @@ async def on_message(message: IncomingMessage):
         'fields': {'probability': msg_json['probability']}
     }
     async with InfluxDBClient(username=config.INFLUXDB_USERNAME, password=config.INFLUXDB_PASSWORD,
-                              host=config.INFLUXDB_HOST, port=config.INFLUXDB_PORT, ssl=False) as client:
-        await client.create_database(db=config.INFLUXDB_DB)
+                              host=config.INFLUXDB_HOST, port=config.INFLUXDB_PORT, ssl=False,
+                              database=config.INFLUXDB_DB) as client:
+        await client.create_database(config.INFLUXDB_DB)
         await client.write(point)