src/FuzeWorks/Async/TaskStorage/RedisTaskStorage.php

@@ -80,6 +80,9 @@ class RedisTaskStorage implements TaskStorage
             // Otherwise attempt authentication, if needed
             if (isset($parameters['password']) && !$this->conn->auth($parameters['password']))
                 throw new TasksException("Could not construct RedisTaskStorage. Authentication failure.");
+
+            // And select the DB index
+            $this->conn->select($parameters['db_index']);
         } catch (RedisException $e) {
             throw new TasksException("Could not construct RedisTaskStorage. RedisException thrown: '" . $e->getMessage() . "'");
         }
@@ -282,7 +285,7 @@ class RedisTaskStorage implements TaskStorage
     {
         // First get the task ID
         $taskId = $task->getId();
-
+        
         // Check if the key already exists
         if (!$this->conn->exists($this->key_prefix . $taskId . '_post_' . $attempt))
             return null;
@@ -296,16 +299,10 @@ class RedisTaskStorage implements TaskStorage
 
     /**
      * @inheritDoc
-     * @throws TasksException
      */
     public function reset(): bool
     {
-        // First get a list of all tasks
+        // Clear the current db
-        foreach ($this->readTasks() as $task)
+        return $this->conn->flushDB();
-            $this->deleteTask($task);
-
-        $this->refreshTasks();
-
-        return true;
     }
 }

test/config.tasks.php

@@ -68,6 +68,7 @@ return array(
             'password' => Core::getEnv('TASKSTORAGE_REDIS_PASSWORD', null),
             'port' => Core::getEnv('TASKSTORAGE_REDIS_PORT', 6379),
             'timeout' => Core::getEnv('TASKSTORAGE_REDIS_TIMEOUT', 0),
+            'db_index' => Core::getEnv('TASKSTORAGE_REDIS_DBINDEX', 0),
         ]
     ],
     'Executor' => [