Python: adds TIME command (valkey-io#1147)

CHANGELOG.md

@@ -19,7 +19,7 @@
 * Node: Added ZREMRANGEBYRANK command ([#924](https://github.com/aws/glide-for-redis/pull/924))
 * Node: Added Xadd, Xtrim commands. ([#1057](https://github.com/aws/glide-for-redis/pull/1057))
 * Python: Added json module and JSON.SET JSON.GET commands  ([#1056](https://github.com/aws/glide-for-redis/pull/1056))
-* Node: Added Time command. ([#1114](https://github.com/aws/glide-for-redis/pull/1114))
+* Python, Node: Added Time command ([#1147](https://github.com/aws/glide-for-redis/pull/1147)), ([#1114](https://github.com/aws/glide-for-redis/pull/1114))
 * Python, Node: Added LINDEX command ([#1058](https://github.com/aws/glide-for-redis/pull/1058), [#999](https://github.com/aws/glide-for-redis/pull/999))
 * Python: Added ZRANK command ([#1065](https://github.com/aws/glide-for-redis/pull/1065))
 * Core: Enabled Cluster Mode periodic checks by default ([#1089](https://github.com/aws/glide-for-redis/pull/1089))

python/python/glide/async_commands/cluster_commands.py

@@ -252,7 +252,7 @@ async def client_getname(
             >>> await client.client_getname()
             'Connection Name'
             >>> await client.client_getname(AllNodes())
-            {'addr': 'Connection Name'', 'addr2': 'Connection Name', 'addr3': 'Connection Name'}
+            {'addr': 'Connection Name', 'addr2': 'Connection Name', 'addr3': 'Connection Name'}
         """
         return cast(
             TClusterResponse[Optional[str]],
@@ -277,3 +277,31 @@ async def dbsize(self, route: Optional[Route] = None) -> int:
                 10  # Indicates there are 10 keys in the cluster.
         """
         return cast(int, await self._execute_command(RequestType.DBSize, [], route))
+
+    async def time(self, route: Optional[Route] = None) -> TClusterResponse[List[str]]:
+        """
+        Returns the server time.
+
+        See https://redis.io/commands/time/ for more details.
+
+        Args:
+            route (Optional[Route]): The command will be routed to a random node, unless `route` is provided,
+            in which case the client will route the command to the nodes defined by `route`.
+
+        Returns:
+            TClusterResponse[Optional[str]]:  The current server time as a two items `array`:
+            A Unix timestamp and the amount of microseconds already elapsed in the current second.
+            The returned `array` is in a [Unix timestamp, Microseconds already elapsed] format.
+            When specifying a route other than a single node, response will be:
+            {Address (str) : response (List[str]) , ... } with type of Dict[str, List[str]].
+
+        Examples:
+            >>> await client.time()
+            ['1710925775', '913580']
+            >>> await client.client_getname(AllNodes())
+            {'addr': ['1710925775', '913580'], 'addr2': ['1710925775', '913580'], 'addr3': ['1710925775', '913580']}
+        """
+        return cast(
+            TClusterResponse[List[str]],
+            await self._execute_command(RequestType.Time, [], route),
+        )

python/python/glide/async_commands/standalone_commands.py

@@ -206,3 +206,23 @@ async def dbsize(self) -> int:
                 10  # Indicates there are 10 keys in the current database.
         """
         return cast(int, await self._execute_command(RequestType.DBSize, []))
+
+    async def time(self) -> List[str]:
+        """
+        Returns the server time.
+
+        See https://redis.io/commands/time/ for more details.
+
+        Returns:
+            List[str]:  The current server time as a two items `array`:
+            A Unix timestamp and the amount of microseconds already elapsed in the current second.
+            The returned `array` is in a [Unix timestamp, Microseconds already elapsed] format.
+
+        Examples:
+            >>> await client.time()
+            ['1710925775', '913580']
+        """
+        return cast(
+            List[str],
+            await self._execute_command(RequestType.Time, []),
+        )

python/python/tests/test_async_client.py

@@ -1580,6 +1580,18 @@ async def test_dbsize(self, redis_client: TRedisClient):
             assert await redis_client.select(1) == OK
             assert await redis_client.dbsize() == 0
 
+    @pytest.mark.parametrize("cluster_mode", [True, False])
+    @pytest.mark.parametrize("protocol", [ProtocolVersion.RESP2, ProtocolVersion.RESP3])
+    async def test_time(self, redis_client: TRedisClient):
+        current_time = int(time.time()) - 1
+        result = await redis_client.time()
+        assert len(result) == 2
+        assert isinstance(result, list)
+        assert isinstance(result[0], str)
+        assert isinstance(result[1], str)
+        assert int(result[0]) > current_time
+        assert 0 < int(result[1]) < 1000000
+
 
 class TestCommandsUnitTests:
     def test_expiry_cmd_args(self):