fix:error getting scheduler_pid

fix #83

Author: cunla

docs/changelog.md

@@ -2,6 +2,10 @@
 
 ## v1.3.1 🌈
 
+### 🐛 Bug Fixes
+
+- Fix workers' page when there are no queues #83
+
 ### 🧰 Maintenance
 
 - Removes psycopg2 dependency (#78)

scheduler/rq_classes.py

@@ -146,8 +146,11 @@ def _get_property(self, prop_name: str, pipeline: Optional[Pipeline] = None):
         connection = pipeline if pipeline is not None else self.connection
         return as_text(connection.hget(self.key, prop_name))
 
-    def scheduler_pid(self) -> int:
-        pid = self.connection.get(RQScheduler.get_locking_key(self.queues[0].name))
+    def scheduler_pid(self) -> Optional[int]:
+        if len(self.queues) == 0:
+            logger.warning("No queues to get scheduler pid from")
+            return None
+        pid = self.connection.get(DjangoScheduler.get_locking_key(self.queues[0].name))
         return int(pid.decode()) if pid is not None else None
 
 

scheduler/templates/admin/scheduler/workers-list.partial.html

@@ -42,12 +42,12 @@
                     </a>
                 </td>
                 <td>{{ worker.get_state }}</td>
-                <td>{{ worker.birth_date|date:"Y-m-d, H:i:s" }}</td>
+                <td>{{ worker.birth_date | date:"Y-m-d, H:i:s" }}</td>
                 <td>{{ worker.hostname }}</td>
-                <td>{{ worker.pid|unlocalize }}</td>
-                <td>{{ worker.total_working_time|default:0|floatformat }}secs</td>
-                <td>{{ worker.successful_job_count|default:0 }}</td>
-                <td>{{ worker.failed_job_count|default:0 }}</td>
+                <td>{{ worker.pid | unlocalize }}</td>
+                <td>{{ worker.total_working_time | default:0 | floatformat }}secs</td>
+                <td>{{ worker.successful_job_count | default:0 }}</td>
+                <td>{{ worker.failed_job_count | default:0 }}</td>
                 <td>{{ worker | worker_scheduler_pid }}</td>
             </tr>
         {% endfor %}