-
-
Save zt9/a56c93ad19ad48e50448 to your computer and use it in GitHub Desktop.
error that I get when I run worker
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
11:15:10 RQ worker u'rq:worker:SH-MBP.9665' started, version 0.5.6 | |
11:15:10 | |
11:15:10 *** Listening on default... | |
11:15:20 default: send_out_appt_confirmation_sms_queue('(V(000)457-0000\np0\nc__builtin__\nset\np1\n((lp2\nL4044L\natp3\nRp4\ntp5\n.') (2525c7d3-d8e5-407c-9679-f2839a0dd245) | |
--------------------------------------------------------------------------- | |
UnpickleError Traceback (most recent call last) | |
/Users/zt9/code/pr2/myapp/worker.py in <module>() | |
21 ipdb.set_trace() | |
---> 23 if __name__ == '__main__': | |
24 with Connection(conn): | |
25 worker = Worker(map(Queue, listen)) | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/worker.pyc in work(self, burst) | |
429 | |
430 job, queue = result | |
--> 431 self.execute_job(job) | |
432 self.heartbeat() | |
433 | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/worker.pyc in execute_job(self, job) | |
494 child_pid = os.fork() | |
495 if child_pid == 0: | |
--> 496 self.main_work_horse(job) | |
497 else: | |
498 self._horse_pid = child_pid | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/worker.pyc in main_work_horse(self, job) | |
531 self.log = logger | |
532 | |
--> 533 success = self.perform_job(job) | |
534 | |
535 # os._exit() is the way to exit from childs after a fork(), in | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/worker.pyc in perform_job(self, job) | |
559 inside the work horse's process. | |
560 """ | |
--> 561 self.prepare_job_execution(job) | |
562 | |
563 with self.connection._pipeline() as pipeline: | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/worker.pyc in prepare_job_execution(self, job) | |
553 | |
554 msg = 'Processing {0} from {1} since {2}' | |
--> 555 self.procline(msg.format(job.func_name, job.origin, time.time())) | |
556 | |
557 def perform_job(self, job): | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/job.pyc in func_name(self) | |
239 def func_name(self): | |
240 if self._func_name is UNEVALUATED: | |
--> 241 self._unpickle_data() | |
242 return self._func_name | |
243 | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/job.pyc in _unpickle_data(self) | |
207 | |
208 def _unpickle_data(self): | |
--> 209 self._func_name, self._instance, self._args, self._kwargs = unpickle(self.data) | |
210 | |
211 @property | |
/Users/zt9/.virtualenvs/pr2/lib/python2.7/site-packages/rq/job.pyc in unpickle(pickled_string) | |
51 obj = loads(pickled_string) | |
52 except Exception as e: | |
---> 53 raise UnpickleError('Could not unpickle', pickled_string, e) | |
54 return obj | |
55 | |
UnpickleError: (u'Could not unpickle', ImportError('cannot import name SmsRecord',)) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment