-
Notifications
You must be signed in to change notification settings - Fork 3
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Redis Publisher connection error in docker container #22
Conversation
I think tests are failing because of this - https://travis-ci.community/t/java-home-is-not-exported-for-arm64-architecture/6993 |
Yes, you're right.
|
Should I edit the travis file to solve that? |
No, its ok to leave for now as travis should fix it soon. And we are planning to move to github actions soon. |
@@ -11,7 +11,7 @@ | |||
|
|||
class RedisPublisher(Publisher): | |||
|
|||
def __init__(self, connection: RedisConnection = RedisConnection(), | |||
def __init__(self, connection: RedisConnection, | |||
publisher_thread_pool: ThreadPoolExecutor = ThreadPoolExecutor(max_workers=4)): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do you think the other defaults will also not be honoured? Like the thread_pool?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think the issue here would only occur because of this default since it uses self.connect()
init which would throw an exception when connection is not successful. Other default arguments do not share the same issue.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok great.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Thanks! |
Solved the issue #15. The error was because of dynamic import initialises default argument
RedisConnection
which leads it to connect withlocalhost:6379
and throw ConnectionError.