We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3a325f9 commit 746a20bCopy full SHA for 746a20b
syncmaster/worker/transfer.py
@@ -1,9 +1,7 @@
1
# SPDX-FileCopyrightText: 2023-2024 MTS PJSC
2
# SPDX-License-Identifier: Apache-2.0
3
-import logging
4
from datetime import datetime, timezone
5
6
-import onetl
7
from asgi_correlation_id import correlation_id
8
from celery import Celery
9
from celery.signals import after_setup_logger, before_task_publish, task_prerun
@@ -27,7 +25,6 @@
27
25
28
26
@celery.task(name="run_transfer_task", bind=True, track_started=True)
29
def run_transfer_task(self: Celery, run_id: int) -> None:
30
- onetl.log.setup_logging(level=logging.INFO)
31
with Session(self.engine) as session:
32
run_transfer(
33
session=session,
0 commit comments