auvipy / cell Goto Github PK

In experimenting with the library, I noticed that

import cell; cell.Actor causes ImportError. It appears to be an issue with Kombu?

/home/matt/.virtualenvs/cardforcoin/src/cell-master/cell/__init__.pyc in __getattr__(self, name)
     32     def __getattr__(self, name):
     33         if name in object_origins:
---> 34             module = __import__(object_origins[name], None, None, [name])
     35             for extra_name in all_by_module[module.__name__]:
     36                 setattr(self, extra_name, getattr(module, extra_name))

/home/matt/.virtualenvs/cardforcoin/src/cell-master/cell/actors.py in <module>()
     23 from cell.exceptions import WrongNumberOfArguments
     24 from .results import AsyncResult
---> 25 from .utils import cached_property, enum, shortuuid, setattr_default
     26 
     27 __all__ = ['Actor']

/home/matt/.virtualenvs/cardforcoin/src/cell-master/cell/utils/__init__.py in <module>()
      7 from collections import namedtuple
      8 
----> 9 from kombu.five import map, filter, zip
     10 from kombu.utils import cached_property, symbol_by_name  # noqa
     11 

ImportError: cannot import name filter

My kombu version is 3.0.22- maybe it's not supported? Perhaps there's a tested version I can downgrade to?

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

We need to enable Travis on this repository and write the .travis.yml configuration file.

I just tried the framework with the latest stable celery version. I followed the instructions as per the documentation. But, they don't seem to work.
As shown in the Demo video, the actor did not get registered in celery when i called spawn method of agent. May be that is why i got "cell.exceptions.NoReplyError: No reply received within time constraint"
after calling "get" on AsyncResult.
Please help.

Kombu updated their APIs. 'ipublish' is deprecated.
This is the error message:
ImportError: cannot import name 'ipublish'

Is this an official Celery project or just an experiment?

Thanks in advance,
DD.

Hi Ask,

As we discussed in IRC, I will help you with integration, but I have some questions.

• You said that the plan is to replace pidbox with cell, but can we do the same thing for a regular tasks?
• Could you please make an outline what should be done before you can merge?

Thanks!

Similar to celery/kombu#1121

Currently import fails with

  File "cell", line 53, in <module>
NameError: name '__file__' is not defined

The demo video in the README is not accessible.

will you celery guys work a lot on it ?

or just a experimentation on actor model theory??

Following import error is being raised whenever tried to import Actor from cell.actors
ImportError: cannot import name 'ipublish' from 'kombu.common

Tried to check source files and adopt the code, only to find another problem with importing Agent from cell.agents. As per the cell documentation, creation of dAgent is required as an import from cell.agents. But, as per latest code, there's no dAgent class, but probably would've changed to Agent

Python environments tried and tested are: 3.7-3.9. All these environments fail.