def METHOD_NAME(self):
    with self.env.getClusterConnectionIfNeeded() as r:
        with pytest.raises(redis.ResponseError) as excinfo:
            assert r.execute_command('TS.ADD', "test", 1, 1.5, "DUPLICATE_POLICY")
        with pytest.raises(redis.ResponseError) as excinfo:
            assert r.execute_command('TS.ADD', "test", 1, 1.5, "DUPLICATE_POLICY", "---------------")