Fix lint issues

lsst-dm · Jan 22, 2025 · 29fb2ec · 29fb2ec
1 parent b270c5b
commit 29fb2ec
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/python/lsst/ctrl/oods/butlerAttendant.py b/python/lsst/ctrl/oods/butlerAttendant.py
@@ -240,7 +240,7 @@ async def send_status_task(self):
                 msg = await self.status_queue.get()
                 await self.csc.send_imageInOODS(msg)
                 self.status_queue.task_done()
-            except asyncio.exceptions.CancelledError as err:
+            except asyncio.exceptions.CancelledError:
                 LOGGER.info("status get task cancelled")
                 return
             except Exception as e:

diff --git a/python/lsst/ctrl/oods/butlerProxy.py b/python/lsst/ctrl/oods/butlerProxy.py
@@ -73,7 +73,7 @@ async def clean_task(self):
         """Call the butler's clean_task method"""
         try:
             await self.butlerInstance.clean_task()
-        except asyncio.exceptions.CancelledError as err:
+        except asyncio.exceptions.CancelledError:
             LOGGER.info("cleaning task cancelled")
 
     async def send_status_task(self):

diff --git a/python/lsst/ctrl/oods/fileIngester.py b/python/lsst/ctrl/oods/fileIngester.py
@@ -182,7 +182,7 @@ def helper_done_callback(self, task):
         if task.exception():
             try:
                 task.result()
-            except Exeception as e:
+            except Exception as e:
                 LOGGER.info(f"Task {task}: {e}")
 
     def run_tasks(self):

diff --git a/python/lsst/ctrl/oods/msgQueue.py b/python/lsst/ctrl/oods/msgQueue.py
@@ -121,7 +121,7 @@ async def dequeue_messages(self):
             with concurrent.futures.ThreadPoolExecutor(max_workers=1) as pool:
                 message_list = await loop.run_in_executor(pool, self._get_messages)
             return message_list
-        except asyncio.exceptions.CancelledError as err:
+        except asyncio.exceptions.CancelledError:
             LOGGER.info("get messages task cancelled")
 
     def commit(self, message):