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

luigid logging: Log less and change logger name #1636

Merged
merged 1 commit into from
Apr 11, 2016
Merged

luigid logging: Log less and change logger name #1636

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
10 changes: 5 additions & 5 deletions luigi/scheduler.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
from luigi.task_status import DISABLED, DONE, FAILED, PENDING, RUNNING, SUSPENDED, UNKNOWN
from luigi.task import Config

logger = logging.getLogger("luigi.server")
logger = logging.getLogger(__name__)


class Scheduler(object):
Expand Down Expand Up @@ -420,8 +420,8 @@ def update_status(self, task, config):
# Mark tasks with no remaining active stakeholders for deletion
if not task.stakeholders:
if task.remove is None:
logger.info("Task %r has stakeholders %r but none remain connected -> might remove "
"task in %s seconds", task.id, task.stakeholders, config.remove_delay)
logger.debug("Task %r has stakeholders %r but none remain connected -> might remove "
"task in %s seconds", task.id, task.stakeholders, config.remove_delay)
task.remove = time.time() + config.remove_delay

# Re-enable task after the disable time expires
Expand Down Expand Up @@ -537,7 +537,7 @@ def _prune_workers(self):
remove_workers = []
for worker in self._state.get_active_workers():
if worker.prune(self._config):
logger.info("Worker %s timed out (no contact for >=%ss)", worker, self._config.worker_disconnect_delay)
logger.debug("Worker %s timed out (no contact for >=%ss)", worker, self._config.worker_disconnect_delay)
remove_workers.append(worker.id)

self._state.inactivate_workers(remove_workers)
Expand Down Expand Up @@ -920,7 +920,7 @@ def dep_func(t):

task = self._state.get_task(task_id)
if task is None or not task.family:
logger.warn('Missing task for id [%s]', task_id)
logger.debug('Missing task for id [%s]', task_id)

# NOTE : If a dependency is missing from self._state there is no way to deduce the
# task family and parameters.
Expand Down