update
This commit is contained in:
parent
d7ae1c92b4
commit
53cfd0a757
2 changed files with 53 additions and 54 deletions
|
|
@ -274,7 +274,6 @@ class GraphDriver(ABC):
|
||||||
response = await client.delete_by_query(
|
response = await client.delete_by_query(
|
||||||
index=index_name,
|
index=index_name,
|
||||||
body={'query': {'match_all': {}}},
|
body={'query': {'match_all': {}}},
|
||||||
slices='auto',
|
|
||||||
)
|
)
|
||||||
logger.info(f"Cleared index '{index_name}': {response}")
|
logger.info(f"Cleared index '{index_name}': {response}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
|
|
||||||
|
|
@ -1013,7 +1013,7 @@ async def episode_fulltext_search(
|
||||||
elif driver.aoss_client:
|
elif driver.aoss_client:
|
||||||
route = group_ids[0] if group_ids else None
|
route = group_ids[0] if group_ids else None
|
||||||
res = await driver.aoss_client.search(
|
res = await driver.aoss_client.search(
|
||||||
EPISODE_INDEX_NAME,
|
index=EPISODE_INDEX_NAME,
|
||||||
params={'routing': route},
|
params={'routing': route},
|
||||||
query={
|
query={
|
||||||
'size': limit,
|
'size': limit,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue