Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

celery worker log format following LOG_FORMAT env#9404 #10016

Merged
merged 10 commits into from
Nov 8, 2024
Merged

celery worker log format following LOG_FORMAT env#9404 #10016

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
b53bce5
celery worker log format following LOG_FORMAT env#9404
invalid-email-address Oct 29, 2024
2b1c2da
fix import block is un-sorted
invalid-email-address Oct 30, 2024
ab5cdc5
fix celery version in pyproject.toml
invalid-email-address Oct 30, 2024
b838704
Update poetry.lock to match pyproject.toml
invalid-email-address Oct 30, 2024
52438a8
Merge branch 'main' into tag_celery
liuhaoran1212 Oct 30, 2024
2e16b18
update poetry.lock to match pyproject.toml_fix
invalid-email-address Oct 31, 2024
4121d69
Merge branch 'tag_celery' of https://bgithub.xyz/liuhaoran1212/dify i…
invalid-email-address Oct 31, 2024
28ac171
fix poetry.lock to match pyproject.toml
invalid-email-address Nov 8, 2024
83bc7f2
Merge branch 'main' into tag_celery
liuhaoran1212 Nov 8, 2024
d2bda54
fix poetry.lock
invalid-email-address Nov 8, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions api/extensions/ext_celery.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
from datetime import timedelta

import pytz
from celery import Celery, Task
from celery.schedules import crontab
from flask import Flask
Expand Down Expand Up @@ -43,6 +44,11 @@ def __call__(self, *args: object, **kwargs: object) -> object:
result_backend=dify_config.CELERY_RESULT_BACKEND,
broker_transport_options=broker_transport_options,
broker_connection_retry_on_startup=True,
worker_log_format=dify_config.LOG_FORMAT,
worker_task_log_format=dify_config.LOG_FORMAT,
worker_logfile=dify_config.LOG_FILE,
worker_hijack_root_logger=False,
timezone=pytz.timezone(dify_config.LOG_TZ),
)

if dify_config.BROKER_USE_SSL:
Expand Down
Loading