File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
model-engine/model_engine_server/infra/gateways Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change 8
8
)
9
9
from model_engine_server .core .celery import TaskVisibility , celery_app
10
10
from model_engine_server .core .config import infra_config
11
+ from model_engine_server .core .loggers import logger_name , make_logger
11
12
from model_engine_server .domain .gateways .task_queue_gateway import TaskQueueGateway
12
13
14
+ logger = make_logger (logger_name ())
13
15
backend_protocol = "abs" if infra_config ().cloud_provider == "azure" else "s3"
14
16
15
17
celery_redis = celery_app (
@@ -72,6 +74,7 @@ def send_task(
72
74
kwargs = kwargs ,
73
75
queue = queue_name ,
74
76
)
77
+ logger .info (f"Task { res .id } sent to queue { queue_name } from gateway" ) # pragma: no cover
75
78
return CreateAsyncTaskV1Response (task_id = res .id )
76
79
77
80
def get_task (self , task_id : str ) -> GetAsyncTaskV1Response :
You can’t perform that action at this time.
0 commit comments