Change druid URL

2022-10-04 21:47:37 +01:00
parent 2a4db7476f
commit 987ba6ed3c
3 changed files with 11 additions and 10 deletions
--- a/core/db/druid.py
+++ b/core/db/druid.py
@@ -114,7 +114,7 @@ class DruidBackend(StorageBackend):
        ss = orjson.dumps(search_query, option=orjson.OPT_INDENT_2)
        ss = ss.decode()
        print(ss)
-        response = requests.post("http://broker:8082/druid/v2", json=search_query)
+        response = requests.post("http://druid:8082/druid/v2", json=search_query)
        response = orjson.loads(response.text)
        print("RESPONSE LEN", len(response))
        # ss = orjson.dumps(response, option=orjson.OPT_INDENT_2)