Traceback (most recent call last):


 "sample.py", line 6, in <module>

client.slowlog_get(num=1000)


 "/home/ec2-user/.pyenv/versions/env/lib/python3.8/site-packages/redis/client.py", line 1466, in slowlog_get

return self.execute_command(*args, decode_responses=decode_responses)


 "/home/ec2-user/.pyenv/versions/env/lib/python3.8/site-packages/rediscluster/client.py", line 552, in execute_command

return self._execute_command(*args, **kwargs)


 "/home/ec2-user/.pyenv/versions/env/lib/python3.8/site-packages/rediscluster/client.py", line 578, in _execute_command

return self._execute_command_on_nodes(node, *args, **kwargs)


 "/home/ec2-user/.pyenv/versions/env/lib/python3.8/site-packages/rediscluster/client.py", line 738, in _execute_command_on_nodes

return self._merge_result(command, res, **kwargs)


 "/home/ec2-user/.pyenv/versions/env/lib/python3.8/site-packages/rediscluster/client.py", line 512, in _merge_result

return self.result_callbacks[command](command, res, **kwargs)
TypeError: <lambda>() got an unexpected keyword argument 'decode_responses'

Traceback (most recent call last):


 "C:\Users\arh5\AppData\Local\Continuum\anaconda3\envs\etlp_conda_dev\lib\multiprocessing\process.py", line 258, in _bootstrap

self.run()


 "C:\Users\arh5\AppData\Local\Continuum\anaconda3\envs\etlp_conda_dev\lib\multiprocessing\process.py", line 93, in run

self._target(*self._args, **self._kwargs)


 "C:\Users\arh5\AppData\Local\Continuum\anaconda3\envs\etlp_conda_dev\lib\site-packages\distributed\process.py", line 181, in _run

target(*args, **kwargs)


 "C:\Users\arh5\AppData\Local\Continuum\anaconda3\envs\etlp_conda_dev\lib\site-packages\distributed\nanny.py", line 587, in _run

worker = Worker(*worker_args, **worker_kwargs)


 "C:\Users\arh5\AppData\Local\Continuum\anaconda3\envs\etlp_conda_dev\lib\site-packages\distributed\worker.py", line 552, in __init__

**kwargs
TypeError: __init__() got an unexpected keyword argument 'local_directory'
