Skip to content

Commit 1efcd03

Browse files
committed
updated log.
1 parent d4f95bf commit 1efcd03

File tree

4 files changed

+394
-282
lines changed

4 files changed

+394
-282
lines changed

oxygent/databases/db_es/jes_es.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111

1212
class JesEs(BaseEs):
13-
def __init__(self, hosts, user, password, maxsize=200, timeout=20):
13+
def __init__(self, hosts, user, password, maxsize=200, timeout=60):
1414
try:
1515
self.client = Elasticsearch(
1616
hosts, http_auth=(user, password), maxsize=maxsize, timeout=timeout
@@ -42,7 +42,9 @@ async def create_index(self, index_name: str, body: dict) -> dict:
4242
if not body:
4343
raise ValueError("The config of the index ca not be empty")
4444

45-
# await self.client.indices.delete(index=index_name) # !!! delete table
45+
# await self._run_sync(
46+
# self.client.indices.delete, index=index_name
47+
# ) # !!! delete table
4648
# Create the index if not exists
4749
if not await self._index_exists(index_name):
4850
return await self._create_new_index(index_name, body)

0 commit comments

Comments
 (0)