|
|
|
|
|
|
|
|
@app.celery.task(queue="dataset") |
|
|
@app.celery.task(queue="dataset") |
|
|
def clean_embedding_cache_task(): |
|
|
def clean_embedding_cache_task(): |
|
|
click.echo(click.style("Start clean embedding cache.", fg="green")) |
|
|
click.echo(click.style("Start clean embedding cache.", fg="green")) |
|
|
clean_days = int(dify_config.CLEAN_DAY_SETTING) |
|
|
|
|
|
|
|
|
clean_days = int(dify_config.PLAN_SANDBOX_CLEAN_DAY_SETTING) |
|
|
start_at = time.perf_counter() |
|
|
start_at = time.perf_counter() |
|
|
thirty_days_ago = datetime.datetime.now() - datetime.timedelta(days=clean_days) |
|
|
thirty_days_ago = datetime.datetime.now() - datetime.timedelta(days=clean_days) |
|
|
while True: |
|
|
while True: |