auvipy/cell

Inconsistency error sending a message

mhluongo opened this issue · 3 comments

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', {})

Any ideas on this? I'm interested in helping out if I can.

@mhluongo Is this resolved? Can you share the resolution?

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.