Inconsistency error sending a message
mhluongo opened this issue · 3 comments
mhluongo commented
I have an actor that I've spawned from a celery-acquired connection. I get the following error when I try to send a message
InconsistencyError:
Cannot route message for exchange 'cl.Importer': Table empty or key no longer exists.
Probably the key ('_kombu.binding.cl.Importer') has been removed from the Redis database.
To replicate,
class Importer(cell.Actor):
class state(cell.Actor.state):
def import(self, batch):
pass
from kombu import Connection
connection = Connection('redis://localhost:6379/0')
actor_agent = dAgent(connection)
importer = actor_agent.spawn(Importer)
importer.send('import', {})
mhluongo commented
Any ideas on this? I'm interested in helping out if I can.
cjgiridhar commented
@mhluongo Is this resolved? Can you share the resolution?
mhluongo commented
Gave up, and took my project in a different direction. The last commit on this was a day before I opened this issue, so I wouldn't get my hopes up.