{"action":"created","issue":{"url":"https://api.github.com/repos/dask/distributed/issues/1320","repository_url":"https://api.github.com/repos/dask/distributed","labels_url":"https://api.github.com/repos/dask/distributed/issues/1320/labels{/name}","comments_url":"https://api.github.com/repos/dask/distributed/issues/1320/comments","events_url":"https://api.github.com/repos/dask/distributed/issues/1320/events","html_url":"https://github.com/dask/distributed/issues/1320","id":248563120,"number":1320,"title":"TypeError for Map and Submit Functions","user":{"login":"camilo-nunez","id":5784228,"avatar_url":"https://avatars1.githubusercontent.com/u/5784228?v=4","gravatar_id":"","url":"https://api.github.com/users/camilo-nunez","html_url":"https://github.com/camilo-nunez","followers_url":"https://api.github.com/users/camilo-nunez/followers","following_url":"https://api.github.com/users/camilo-nunez/following{/other_user}","gists_url":"https://api.github.com/users/camilo-nunez/gists{/gist_id}","starred_url":"https://api.github.com/users/camilo-nunez/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/camilo-nunez/subscriptions","organizations_url":"https://api.github.com/users/camilo-nunez/orgs","repos_url":"https://api.github.com/users/camilo-nunez/repos","events_url":"https://api.github.com/users/camilo-nunez/events{/privacy}","received_events_url":"https://api.github.com/users/camilo-nunez/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2017-08-07T23:55:41Z","updated_at":"2017-08-08T05:45:53Z","closed_at":null,"body":"Hi,\r\nI trying to run the [Map and Submit Functions](https://distributed.readthedocs.io/en/latest/quickstart.html#map-and-submit-functions) code, and i get this error:\r\n\r\n```\r\n ---------------------------------------------------------------------------\r\nTypeError                                 Traceback (most recent call last)\r\n<ipython-input-9-8a0e66378b58> in <module>()\r\n----> 1 total.result()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/client.py in result(self, timeout)\r\n    153                       self._result, raiseit=False, callback_timeout=timeout)\r\n    154         if self.status == 'error':\r\n--> 155             six.reraise(*result)\r\n    156         elif self.status == 'cancelled':\r\n    157             raise result\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)\r\n    683             value = tp()\r\n    684         if value.__traceback__ is not tb:\r\n--> 685             raise value.with_traceback(tb)\r\n    686         raise value\r\n    687 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py in loads()\r\n     57 def loads(x):\r\n     58     try:\r\n---> 59         return pickle.loads(x)\r\n     60     except Exception:\r\n     61         logger.info(\"Failed to deserialize %s\", x[:10000], exc_info=True)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py in _make_skel_func()\r\n    798 \r\n    799 # Tornado support\r\n--> 800 \r\n    801 def is_tornado_coroutine(func):\r\n    802     \"\"\"\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py in _reconstruct_closure()\r\n    790     dispatch[type(Ellipsis)] = save_ellipsis\r\n    791     dispatch[type(NotImplemented)] = save_not_implemented\r\n--> 792 \r\n    793     \"\"\"Special functions for Add-on libraries\"\"\"\r\n    794     def inject_addons(self):\r\n\r\nTypeError: 'int' object is not iterable\r\n```\r\n\r\nThis is my code:\r\n```\r\n>>> from dask.distributed import Client\r\n>>> client = Client('10.6.91.16:8786')\r\n>>> def square(x):return x ** 2\r\n>>> def neg(x): return -x\r\n>>> A = client.map(square, range(10))\r\n>>> B = client.map(neg, A)\r\n>>> total = client.submit(sum, B)\r\n>>> total.result()\r\n```\r\n\r\nAnd the log:\r\n```\r\n\r\n---------------------------------------------------------------\r\n                 Dask.distributed v1.18.0\r\n\r\nWorker nodes:\r\n  0: 10.6.91.16\r\n  1: 10.6.91.17\r\n  2: 10.6.91.18\r\n\r\nscheduler node: 10.6.91.16:8786\r\n---------------------------------------------------------------\r\n\r\n\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : /root/anaconda3/bin/python -m distributed.cli.dask_scheduler --port 8786\r\n[ worker 10.6.91.18 ] : /root/anaconda3/bin/python -m distributed.cli.dask_worker 10.6.91.16:8786 --nthreads 0 --nprocs 1 --host 10.6.91.18\r\n[ worker 10.6.91.16 ] : /root/anaconda3/bin/python -m distributed.cli.dask_worker 10.6.91.16:8786 --nthreads 0 --nprocs 1 --host 10.6.91.16\r\n[ worker 10.6.91.17 ] : /root/anaconda3/bin/python -m distributed.cli.dask_worker 10.6.91.16:8786 --nthreads 0 --nprocs 1 --host 10.6.91.17\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - -----------------------------------------------\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO -   Scheduler at:     tcp://10.6.91.16:8786\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO -        http at:              0.0.0.0:9786\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO -       bokeh at:              0.0.0.0:8787\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Local Directory:    /tmp/scheduler-7kz8j22m\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - -----------------------------------------------\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Receive client connection: Client-51871f18-7bd0-11e7-a26b-688f84f400a4\r\n[ worker 10.6.91.18 ] : distributed.nanny - INFO -         Start Nanny at: 'tcp://10.6.91.18:54118'\r\n[ worker 10.6.91.16 ] : distributed.nanny - INFO -         Start Nanny at: 'tcp://10.6.91.16:45546'\r\n[ worker 10.6.91.17 ] : distributed.nanny - INFO -         Start Nanny at: 'tcp://10.6.91.17:42940'\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Register tcp://10.6.91.18:60668\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Starting worker compute stream, tcp://10.6.91.18:60668\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -       Start worker at:     tcp://10.6.91.18:60668\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -              nanny at:           10.6.91.18:54118\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -               http at:           10.6.91.18:53053\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -              bokeh at:           10.6.91.18:8789\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO - Waiting to connect to:      tcp://10.6.91.16:8786\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -               Threads:                         24\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -                Memory:                   81.04 GB\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -       Local Directory:        /tmp/nanny-i6gzdo_d\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO -         Registered to:            tcp://10.6.91.16:8786\r\n[ worker 10.6.91.18 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.18 ] : distributed.nanny - INFO - Nanny 'tcp://10.6.91.18:54118' starts worker process 'tcp://10.6.91.18:60668'\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -       Start worker at:     tcp://10.6.91.16:49142\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -              nanny at:           10.6.91.16:45546\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -               http at:           10.6.91.16:46230\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -              bokeh at:           10.6.91.16:8789\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO - Waiting to connect to:      tcp://10.6.91.16:8786\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -               Threads:                         24\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -                Memory:                   81.04 GB\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -       Local Directory:            worker-txgwpmfn\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO -         Registered to:            tcp://10.6.91.16:8786\r\n[ worker 10.6.91.16 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -       Start worker at:     tcp://10.6.91.17:51286\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -              nanny at:           10.6.91.17:42940\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -               http at:           10.6.91.17:38683\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -              bokeh at:           10.6.91.17:8789\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO - Waiting to connect to:      tcp://10.6.91.16:8786\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -               Threads:                         24\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -                Memory:                   81.04 GB\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -       Local Directory:        /tmp/nanny-9jmfebch\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO -         Registered to:            tcp://10.6.91.16:8786\r\n[ worker 10.6.91.17 ] : distributed.worker - INFO - -------------------------------------------------\r\n[ worker 10.6.91.17 ] : distributed.nanny - INFO - Nanny 'tcp://10.6.91.17:42940' starts worker process 'tcp://10.6.91.17:51286'\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Register tcp://10.6.91.16:49142\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Starting worker compute stream, tcp://10.6.91.16:49142\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Register tcp://10.6.91.17:51286\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Starting worker compute stream, tcp://10.6.91.17:51286\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - INFO - Receive client connection: Client-aca8198a-7bd0-11e7-a26b-688f84f400a4\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.18:60668: 'int' object is not iterable\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.18:60668: 'int' object is not iterable\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.18:60668: 'int' object is not iterable\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.17:51286: 'int' object is not iterable\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.17:51286: 'int' object is not iterable\r\n[ \u001B[1mscheduler 10.6.91.16:8786\u001B[0m ] : distributed.scheduler - ERROR - error from worker tcp://10.6.91.17:51286: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.18 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.18 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.18 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.18 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.18 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.18 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.18 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.18 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.18 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.18 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.18 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.18 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.18 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.17 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.17 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.17 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.17 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.protocol.pickle - INFO - Failed to deserialize b'\\x80\\x04\\x95\\xd3\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x8c\\x17cloudpickle.cloudpickle\\x94\\x8c\\x0e_fill_function\\x94\\x93\\x94(h\\x00\\x8c\\x0f_make_skel_func\\x94\\x93\\x94h\\x00\\x8c\\r_builtin_type\\x94\\x93\\x94\\x8c\\x08CodeType\\x94\\x85\\x94R\\x94(K\\x01K\\x00K\\x01K\\x02KCC\\x08|\\x00d\\x01\\x13\\x00S\\x00\\x94NK\\x02\\x86\\x94)\\x8c\\x01x\\x94\\x85\\x94\\x8c\\x1f<ipython-input-14-3aaa64e15a6c>\\x94\\x8c\\x06square\\x94K\\x01C\\x00\\x94))t\\x94R\\x94J\\xff\\xff\\xff\\xff}\\x94\\x87\\x94R\\x94}\\x94N}\\x94NtR.'\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n[ worker 10.6.91.17 ] : distributed.worker - WARNING - Could not deserialize task\r\n[ worker 10.6.91.17 ] : Traceback (most recent call last):\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 1090, in add_task\r\n[ worker 10.6.91.17 ] :     self.tasks[key] = _deserialize(function, args, kwargs, task)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 549, in _deserialize\r\n[ worker 10.6.91.17 ] :     function = pickle.loads(function)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n[ worker 10.6.91.17 ] :     return pickle.loads(x)\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n[ worker 10.6.91.17 ] :     closure = _reconstruct_closure(closures) if closures else None\r\n[ worker 10.6.91.17 ] :   File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\n[ worker 10.6.91.17 ] :     return tuple([_make_cell(v) for v in values])\r\n[ worker 10.6.91.17 ] : TypeError: 'int' object is not iterable\r\n\r\n[ dask-ssh ]: Shutting down remote processes (this may take a moment).\r\n\r\n```\r\n\r\nWhat do you think about it?"},"comment":{"url":"https://api.github.com/repos/dask/distributed/issues/comments/320856567","html_url":"https://github.com/dask/distributed/issues/1320#issuecomment-320856567","issue_url":"https://api.github.com/repos/dask/distributed/issues/1320","id":320856567,"user":{"login":"camilo-nunez","id":5784228,"avatar_url":"https://avatars1.githubusercontent.com/u/5784228?v=4","gravatar_id":"","url":"https://api.github.com/users/camilo-nunez","html_url":"https://github.com/camilo-nunez","followers_url":"https://api.github.com/users/camilo-nunez/followers","following_url":"https://api.github.com/users/camilo-nunez/following{/other_user}","gists_url":"https://api.github.com/users/camilo-nunez/gists{/gist_id}","starred_url":"https://api.github.com/users/camilo-nunez/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/camilo-nunez/subscriptions","organizations_url":"https://api.github.com/users/camilo-nunez/orgs","repos_url":"https://api.github.com/users/camilo-nunez/repos","events_url":"https://api.github.com/users/camilo-nunez/events{/privacy}","received_events_url":"https://api.github.com/users/camilo-nunez/received_events","type":"User","site_admin":false},"created_at":"2017-08-08T05:45:53Z","updated_at":"2017-08-08T05:45:53Z","body":"This is the output:\r\n\r\n```\r\ndistributed.utils - ERROR - 'int' object is not iterable\r\nTraceback (most recent call last):\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/utils.py\", line 223, in f\r\n    result[0] = yield make_coro()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1063, in run\r\n    yielded = self.gen.throw(*exc_info)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/client.py\", line 1723, in _run\r\n    workers=workers, nanny=nanny)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1063, in run\r\n    yielded = self.gen.throw(*exc_info)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/core.py\", line 430, in send_recv_from_rpc\r\n    result = yield send_recv(comm=comm, op=key, **kwargs)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1069, in run\r\n    yielded = self.gen.send(value)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/core.py\", line 330, in send_recv\r\n    six.reraise(*clean_exception(**response))\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/six.py\", line 685, in reraise\r\n    raise value.with_traceback(tb)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/core.py\", line 266, in handle_comm\r\n    result = yield result\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1063, in run\r\n    yielded = self.gen.throw(*exc_info)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/scheduler.py\", line 1607, in broadcast\r\n    for address in addresses\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1063, in run\r\n    yielded = self.gen.throw(*exc_info)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/utils.py\", line 189, in All\r\n    result = yield tasks.next()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1063, in run\r\n    yielded = self.gen.throw(*exc_info)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/scheduler.py\", line 1603, in send_message\r\n    resp = yield send_recv(comm, close=True, **msg)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1069, in run\r\n    yielded = self.gen.send(value)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/core.py\", line 330, in send_recv\r\n    six.reraise(*clean_exception(**response))\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/six.py\", line 685, in reraise\r\n    raise value.with_traceback(tb)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/core.py\", line 266, in handle_comm\r\n    result = yield result\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 1055, in run\r\n    value = future.result()\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py\", line 238, in result\r\n    raise_exc_info(self._exc_info)\r\n  File \"<string>\", line 4, in raise_exc_info\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py\", line 307, in wrapper\r\n    yielded = next(result)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py\", line 761, in run\r\n    function = pickle.loads(function)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py\", line 59, in loads\r\n    return pickle.loads(x)\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 800, in _make_skel_func\r\n  File \"/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py\", line 792, in _reconstruct_closure\r\nTypeError: 'int' object is not iterable\r\n\r\n---------------------------------------------------------------------------\r\nTypeError                                 Traceback (most recent call last)\r\n<ipython-input-4-13767d2792b6> in <module>()\r\n----> 1 client.get_versions(check=True)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/client.py in get_versions(self, check)\r\n   2541                 return None\r\n   2542 \r\n-> 2543         workers = sync(self.loop, self._run, f)\r\n   2544         result = {'scheduler': scheduler, 'workers': workers, 'client': client}\r\n   2545 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/utils.py in sync(loop, func, *args, **kwargs)\r\n    232         e.wait(1000000)\r\n    233     if error[0]:\r\n--> 234         six.reraise(*error[0])\r\n    235     else:\r\n    236         return result[0]\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)\r\n    684         if value.__traceback__ is not tb:\r\n    685             raise value.with_traceback(tb)\r\n--> 686         raise value\r\n    687 \r\n    688 else:\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/utils.py in f()\r\n    221                 raise RuntimeError(\"sync() called from thread of running loop\")\r\n    222             yield gen.moment\r\n--> 223             result[0] = yield make_coro()\r\n    224         except Exception as exc:\r\n    225             logger.exception(exc)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result(self, timeout)\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info(exc_info)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1061                     if exc_info is not None:\r\n   1062                         try:\r\n-> 1063                             yielded = self.gen.throw(*exc_info)\r\n   1064                         finally:\r\n   1065                             # Break up a reference to itself\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/client.py in _run(self, function, *args, **kwargs)\r\n   1721                                                 args=dumps(args),\r\n   1722                                                 kwargs=dumps(kwargs)),\r\n-> 1723                                                 workers=workers, nanny=nanny)\r\n   1724         results = {}\r\n   1725         for key, resp in responses.items():\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result(self, timeout)\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info(exc_info)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1061                     if exc_info is not None:\r\n   1062                         try:\r\n-> 1063                             yielded = self.gen.throw(*exc_info)\r\n   1064                         finally:\r\n   1065                             # Break up a reference to itself\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/core.py in send_recv_from_rpc(**kwargs)\r\n    428             try:\r\n    429                 comm = yield self.live_comm()\r\n--> 430                 result = yield send_recv(comm=comm, op=key, **kwargs)\r\n    431             except (RPCClosed, CommClosedError) as e:\r\n    432                 raise e.__class__(\"%s: while trying to call remote method %r\"\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result(self, timeout)\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info(exc_info)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1067                             exc_info = None\r\n   1068                     else:\r\n-> 1069                         yielded = self.gen.send(value)\r\n   1070 \r\n   1071                     if stack_context._state.contexts is not orig_stack_contexts:\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/core.py in send_recv(comm, reply, deserialize, **kwargs)\r\n    328 \r\n    329     if isinstance(response, dict) and response.get('status') == 'uncaught-error':\r\n--> 330         six.reraise(*clean_exception(**response))\r\n    331     raise gen.Return(response)\r\n    332 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)\r\n    683             value = tp()\r\n    684         if value.__traceback__ is not tb:\r\n--> 685             raise value.with_traceback(tb)\r\n    686         raise value\r\n    687 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/core.py in handle_comm()\r\n    264                         result = handler(comm, **msg)\r\n    265                         if type(result) is gen.Future:\r\n--> 266                             result = yield result\r\n    267                     except CommClosedError as e:\r\n    268                         logger.warning(\"Lost connection to %r: %s\", address, e)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result()\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1061                     if exc_info is not None:\r\n   1062                         try:\r\n-> 1063                             yielded = self.gen.throw(*exc_info)\r\n   1064                         finally:\r\n   1065                             # Break up a reference to itself\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/scheduler.py in broadcast()\r\n   1605 \r\n   1606         results = yield All([send_message(self.coerce_address(address))\r\n-> 1607                              for address in addresses\r\n   1608                              if address is not None])\r\n   1609 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result()\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1061                     if exc_info is not None:\r\n   1062                         try:\r\n-> 1063                             yielded = self.gen.throw(*exc_info)\r\n   1064                         finally:\r\n   1065                             # Break up a reference to itself\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/utils.py in All()\r\n    187     results = [None for _ in args]\r\n    188     while not tasks.done():\r\n--> 189         result = yield tasks.next()\r\n    190         results[tasks.current_index] = result\r\n    191     raise gen.Return(results)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result()\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1061                     if exc_info is not None:\r\n   1062                         try:\r\n-> 1063                             yielded = self.gen.throw(*exc_info)\r\n   1064                         finally:\r\n   1065                             # Break up a reference to itself\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/scheduler.py in send_message()\r\n   1601             comm = yield connect(addr, deserialize=self.deserialize,\r\n   1602                                  connection_args=self.connection_args)\r\n-> 1603             resp = yield send_recv(comm, close=True, **msg)\r\n   1604             raise gen.Return(resp)\r\n   1605 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result()\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1067                             exc_info = None\r\n   1068                     else:\r\n-> 1069                         yielded = self.gen.send(value)\r\n   1070 \r\n   1071                     if stack_context._state.contexts is not orig_stack_contexts:\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/core.py in send_recv()\r\n    328 \r\n    329     if isinstance(response, dict) and response.get('status') == 'uncaught-error':\r\n--> 330         six.reraise(*clean_exception(**response))\r\n    331     raise gen.Return(response)\r\n    332 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/six.py in reraise()\r\n    683             value = tp()\r\n    684         if value.__traceback__ is not tb:\r\n--> 685             raise value.with_traceback(tb)\r\n    686         raise value\r\n    687 \r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/core.py in handle_comm()\r\n    264                         result = handler(comm, **msg)\r\n    265                         if type(result) is gen.Future:\r\n--> 266                             result = yield result\r\n    267                     except CommClosedError as e:\r\n    268                         logger.warning(\"Lost connection to %r: %s\", address, e)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in run()\r\n   1053 \r\n   1054                     try:\r\n-> 1055                         value = future.result()\r\n   1056                     except Exception:\r\n   1057                         self.had_exception = True\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/concurrent.py in result()\r\n    236         if self._exc_info is not None:\r\n    237             try:\r\n--> 238                 raise_exc_info(self._exc_info)\r\n    239             finally:\r\n    240                 self = None\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/util.py in raise_exc_info()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/tornado/gen.py in wrapper()\r\n    305                 try:\r\n    306                     orig_stack_contexts = stack_context._state.contexts\r\n--> 307                     yielded = next(result)\r\n    308                     if stack_context._state.contexts is not orig_stack_contexts:\r\n    309                         yielded = TracebackFuture()\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/worker.py in run()\r\n    759 def run(server, comm, function, args=(), kwargs={}, is_coro=False, wait=True):\r\n    760     assert wait or is_coro, \"Combination not supported\"\r\n--> 761     function = pickle.loads(function)\r\n    762     if args:\r\n    763         args = pickle.loads(args)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/distributed/protocol/pickle.py in loads()\r\n     57 def loads(x):\r\n     58     try:\r\n---> 59         return pickle.loads(x)\r\n     60     except Exception:\r\n     61         logger.info(\"Failed to deserialize %s\", x[:10000], exc_info=True)\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py in _make_skel_func()\r\n    798 \r\n    799 # Tornado support\r\n--> 800 \r\n    801 def is_tornado_coroutine(func):\r\n    802     \"\"\"\r\n\r\n/root/anaconda3/lib/python3.6/site-packages/cloudpickle/cloudpickle.py in _reconstruct_closure()\r\n    790     dispatch[type(Ellipsis)] = save_ellipsis\r\n    791     dispatch[type(NotImplemented)] = save_not_implemented\r\n--> 792 \r\n    793     \"\"\"Special functions for Add-on libraries\"\"\"\r\n    794     def inject_addons(self):\r\n\r\nTypeError: 'int' object is not iterable\r\n```"}}
{"actor":{"display_login":"camilo-nunez"}}