Naming changes

Author: neob91-close

tasktiger/task.py

@@ -345,7 +345,7 @@ def _move(self, from_state=None, to_state=None, when=None, mode=None):
         )
 
         if to_state == QUEUED:
-            self.tiger._notify_queue(queue, client=pipeline)
+            self.tiger._notify_task_queued(queue, client=pipeline)
 
         try:
             scripts.execute_pipeline(pipeline)
@@ -422,7 +422,7 @@ def delay(self, when=None, max_queue_size=None):
         )
 
         if state == QUEUED:
-            tiger._notify_queue(self.queue, client=pipeline)
+            tiger._notify_task_queued(self.queue, client=pipeline)
 
         pipeline.execute()
 

tasktiger/tasktiger.py

@@ -265,7 +265,7 @@ def _get_current_tasks(self):
     current_task = property(_get_current_task)
     current_tasks = property(_get_current_tasks)
 
-    def _notify_queue(self, queue, client=None):
+    def _notify_task_queued(self, queue, client=None):
         _client = client or self.connection.pipeline(transaction=False)
 
         if self.config["PUBLISH_QUEUED_TASKS"]:
@@ -275,7 +275,7 @@ def _notify_queue(self, queue, client=None):
         if cache_token_expiry > 0:
             for queue_part in list(dotted_parts(queue)) + [""]:
                 _client.set(
-                    self._key("queue_cache_token", queue_part),
+                    self._key("queued_cache_token", queue_part),
                     secrets.token_hex(),
                     ex=cache_token_expiry,
                 )

tasktiger/worker.py

@@ -223,7 +223,7 @@ def _worker_queue_scheduled_tasks(self) -> None:
             # XXX: ideally this would be in the same pipeline, but we only want
             # to announce if there was a result.
             if result:
-                self.tiger._notify_queue(queue)
+                self.tiger._notify_task_queued(queue)
                 self._did_work = True
 
     def _poll_for_queues(self) -> None:
@@ -263,7 +263,7 @@ def _should_poll_for_queues(self) -> bool:
 
     def _get_queue_cache_tokens(self) -> Tuple[Optional[str], ...]:
         keys = sorted(
-            self._key("queue_cache_token", queue)
+            self._key("queued_cache_token", queue)
             for queue in self.only_queues or [""]
         )