- Notifications
You must be signed in to change notification settings - Fork182
Closed
Milestone
Description
examples/import_data_set_multiprocessing.py
Error executing multiprocessing example are reactivex upgrade.
Unexpected error: 'Future' object is not iterableTraceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/reactivex/observable/observable.py", line 125, in set_disposable subscriber = self._subscribe_core(auto_detach_observer, scheduler) File "/usr/local/lib/python3.9/site-packages/reactivex/observable/observable.py", line 49, in _subscribe_core return self._subscribe(observer, scheduler) if self._subscribe else Disposable() File "/usr/local/lib/python3.9/site-packages/reactivex/observable/fromiterable.py", line 31, in subscribe iterator = iter(iterable)TypeError: 'Future' object is not iterable