resolve review comments

sodafoundation · Mar 24, 2021 · a087e99 · a087e99
1 parent fa2e42c
commit a087e99
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/delfin/task_manager/scheduler/schedulers/telemetry/failed_telemetry_job.py b/delfin/task_manager/scheduler/schedulers/telemetry/failed_telemetry_job.py
@@ -41,8 +41,7 @@ def __call__(self):
  :return:
  """
  try:
- # Remove jobs from scheduler for deleted failed_tasks
- # Remove jobs from scheduler if it is added
+ # Remove jobs from scheduler when marked for delete
  filters = {'deleted': True}
  failed_tasks = db.failed_task_get_all(self.ctx, filters=filters)
  LOG.debug("Total failed_tasks found deleted "
@@ -56,7 +55,7 @@ def __call__(self):
  LOG.error("Failed to remove periodic scheduling job , reason: %s.",
  six.text_type(e))
  try:
- # create the object of periodic scheduler
+ # Create the object of periodic scheduler
  failed_tasks = db.failed_task_get_all(self.ctx)
 
  if not len(failed_tasks):

diff --git a/delfin/task_manager/scheduler/schedulers/telemetry/telemetry_job.py b/delfin/task_manager/scheduler/schedulers/telemetry/telemetry_job.py
@@ -42,8 +42,7 @@ def __init__(self, ctxt):
  def __call__(self, ctx):
  """ Schedule the collection tasks based on interval """
  try:
- # Remove jobs from scheduler for deleted tasks
- # Remove jobs from scheduler if it is added
+ # Remove jobs from scheduler when marked for delete
  filters = {'deleted': True}
  tasks = db.task_get_all(ctx, filters=filters)
  LOG.debug("Total tasks found deleted "