You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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', {})
The text was updated successfully, but these errors were encountered:
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
To replicate,
The text was updated successfully, but these errors were encountered: