Closed komuw closed 5 years ago
We actually need the broker check.
this is because we want to give the broker a chance to have created the queue_name so that by the time we do; self.the_broker.enqueue(queue_name=self.queue_name, item=proto.json())
it will work.
ie, remove: https://github.com/komuw/wiji/blob/db3ecfada431aa419c4c5d23ebd41d4ef1b2e928/wiji/task.py#L515-L516
after all, we will call https://github.com/komuw/wiji/blob/db3ecfada431aa419c4c5d23ebd41d4ef1b2e928/wiji/task.py#L531 soon after and that will tell us whether broker is okay or not