Last active
March 8, 2016 20:05
-
-
Save martindurant/92f670cb4054905690e5 to your computer and use it in GitHub Desktop.
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
| ============================= test session starts ============================== | |
| platform darwin -- Python 3.4.4, pytest-2.8.5, py-1.4.31, pluggy-0.3.1 -- /Users/mdurant/Documents/anaconda/bin/python | |
| cachedir: .cache | |
| rootdir: /Users/mdurant/Downloads/distributed, inifile: | |
| collecting ... collected 300 items / 2 errors | |
| distributed/cli/tests/test_dscheduler.py::test_defaults PASSED | |
| distributed/diagnostics/tests/test_plugin.py::test_diagnostic <- distributed/utils_test.py Start: 8, End: 9 | |
| PASSED | |
| distributed/diagnostics/tests/test_progress.py::test_dependent_keys PASSED | |
| distributed/diagnostics/tests/test_progress.py::test_robust_to_bad_plugin <- distributed/utils_test.py Start: 9, End: 9 | |
| PASSED | |
| distributed/diagnostics/tests/test_progress.py::test_multiprogress <- distributed/utils_test.py Start: 9, End: 9 | |
| PASSED | |
| distributed/diagnostics/tests/test_progress.py::test_many_Progresss <- distributed/utils_test.py Start: 9, End: 9 | |
| PASSED | |
| distributed/diagnostics/tests/test_progressbar.py::test_text_progressbar Start: 12, End: 33 | |
| PASSED | |
| distributed/diagnostics/tests/test_progressbar.py::test_TextProgressBar_empty distributed.scheduler - CRITICAL - Lost all workers | |
| PASSED | |
| distributed/diagnostics/tests/test_progressbar.py::test_progress_function Start: 33, End: 36 | |
| PASSED | |
| distributed/diagnostics/tests/test_progressbar.py::test_TextProgressBar_error <- distributed/utils_test.py | |
| [ ] | 0% Completed | 0.0s | |
| [ ] | 0% Completed | 0.0s | |
| [ ] | 0% Completed | 0.0sStart: 33, End: 37 | |
| PASSED | |
| distributed/diagnostics/tests/test_resource_monitor.py::test_occupancy Start: 40, End: 55 | |
| PASSED | |
| distributed/diagnostics/tests/test_scheduler_diagnostic_widgets.py::test_scheduler_status_widget PASSED | |
| distributed/diagnostics/tests/test_scheduler_diagnostic_widgets.py::test_scheduler_status <- distributed/utils_test.py Start: 51, End: 52 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_values Start: 55, End: 55 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_progressbar_done Start: 55, End: 55 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_fast Start: 55, End: 55 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_multi_progressbar_widget_after_close <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_progressbar_widget <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_multibar_complete <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/diagnostics/tests/test_widgets.py::test_multi_progressbar_widget <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_services_with_port <- distributed/utils_test.py PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_services <- distributed/utils_test.py PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_with_status <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_broadcast <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_simple <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_processing <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_with_data <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_scheduler_http.py::test_proxy <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_worker_http.py::test_simple <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_worker_http.py::test_services <- distributed/utils_test.py Start: 52, End: 52 | |
| PASSED | |
| distributed/http/tests/test_worker_http.py::test_services_port <- distributed/utils_test.py Start: 52, End: 54 | |
| PASSED | |
| distributed/tests/test_center.py::test_metadata <- distributed/utils_test.py PASSED | |
| distributed/tests/test_client.py::test_scatter_delete PASSED | |
| distributed/tests/test_client.py::test_gather_with_missing_worker PASSED | |
| distributed/tests/test_client.py::test_pack_data PASSED | |
| distributed/tests/test_client.py::test_pack_data_with_key_mapping PASSED | |
| distributed/tests/test_client.py::test_gather_errors_voluminously PASSED | |
| distributed/tests/test_client.py::test_gather_scatter SKIPPED | |
| distributed/tests/test_client.py::test_clear PASSED | |
| distributed/tests/test_client.py::test_scatter_round_robins_between_calls PASSED | |
| distributed/tests/test_client.py::test_broadcast_to_workers <- distributed/utils_test.py Start: 55, End: 52 | |
| PASSED | |
| distributed/tests/test_cluster.py::test_cluster SKIPPED | |
| distributed/tests/test_collections.py::test_futures_to_dask_dataframe Setting global dask scheduler to use distributed | |
| Start: 55, End: 55 | |
| PASSED | |
| distributed/tests/test_collections.py::test_futures_to_dask_arrays Setting global dask scheduler to use distributed | |
| Start: 55, End: 55 | |
| PASSED | |
| distributed/tests/test_collections.py::test_futures_to_dask_bag Setting global dask scheduler to use distributed | |
| Start: 55, End: 55 | |
| PASSED | |
| distributed/tests/test_collections.py::test_futures_to_dask_array SKIPPED | |
| distributed/tests/test_collections.py::test_no_divisions <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 52, End: 52 | |
| PASSED | |
| distributed/tests/test_collections.py::test__futures_to_dask_array <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 52, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test_dataframes <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__dask_array_collections <- distributed/utils_test.py Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__future_to_dask_array <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__futures_to_dask_bag <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__futures_to_dask_dataframe <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__futures_to_dask_arrays <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_collections.py::test__futures_to_collection <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 50, End: 50 | |
| PASSED | |
| distributed/tests/test_core.py::test_server PASSED | |
| distributed/tests/test_core.py::test_rpc PASSED | |
| distributed/tests/test_core.py::test_rpc_inputs PASSED | |
| distributed/tests/test_core.py::test_rpc_with_many_connections PASSED | |
| distributed/tests/test_core.py::test_large_packets SKIPPED | |
| distributed/tests/test_core.py::test_identity PASSED | |
| distributed/tests/test_core.py::test_ports PASSED | |
| distributed/tests/test_core.py::test_errors PASSED | |
| distributed/tests/test_core.py::test_coerce_to_rpc PASSED | |
| distributed/tests/test_executor.py::test_thread /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 1) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 0) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 2) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 3) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 4) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((2, 3, 4), 5) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/numpy/core/numeric.py:294: FutureWarning: in the future, full((), 0) will return an array of dtype('int64') | |
| format(shape, fill_value, array(fill_value).dtype), FutureWarning) | |
| /Users/mdurant/Documents/anaconda/lib/python3.4/site-packages/pandas/core/groupby.py:3879: RuntimeWarning: divide by zero encountered in long_scalars | |
| stride //= shape[i] | |
| Start: 53, End: 53 | |
| PASSED | |
| distributed/tests/test_executor.py::test_sync_exceptions Start: 53, End: 53 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_sync Start: 53, End: 71 | |
| PASSED | |
| distributed/tests/test_executor.py::test_get_sync Start: 71, End: 80 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit_errors PASSED | |
| distributed/tests/test_executor.py::test_as_completed Start: 80, End: 80 | |
| PASSED | |
| distributed/tests/test_executor.py::test_wait_sync Start: 80, End: 80 | |
| PASSED | |
| distributed/tests/test_executor.py::test_stress_gc[func0-100] Start: 80, End: 71 | |
| PASSED | |
| distributed/tests/test_executor.py::test_stress_gc[func1-1000] Start: 71, End: 71 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit_after_failed_worker Start: 71, End: 71 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_after_failed_worker Start: 71, End: 80 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_then_submit_after_failed_workers SKIPPED | |
| distributed/tests/test_executor.py::test_global_executors Start: 80, End: 98 | |
| PASSED | |
| distributed/tests/test_executor.py::test_get_with_error_sync Start: 98, End: 116 | |
| PASSED | |
| distributed/tests/test_executor.py::test_directed_scatter_sync Start: 116, End: 125 | |
| PASSED | |
| distributed/tests/test_executor.py::test_iterator_scatter Start: 125, End: 125 | |
| PASSED | |
| distributed/tests/test_executor.py::test_queue_scatter Start: 125, End: 143 | |
| PASSED | |
| distributed/tests/test_executor.py::test_queue_gather Start: 143, End: 143 | |
| PASSED | |
| distributed/tests/test_executor.py::test_iterator_gather Exception in thread Thread-95: | |
| Traceback (most recent call last): | |
| File "/Users/mdurant/Documents/anaconda/lib/python3.4/threading.py", line 911, in _bootstrap_inner | |
| self.run() | |
| File "/Users/mdurant/Documents/anaconda/lib/python3.4/threading.py", line 859, in run | |
| self._target(*self._args, **self._kwargs) | |
| File "/Users/mdurant/Downloads/distributed/distributed/executor.py", line 782, in _threaded_scatter | |
| [f] = self.scatter([d], **kwargs) | |
| TypeError: 'NoneType' object is not iterable | |
| Start: 143, End: 161 | |
| PASSED | |
| distributed/tests/test_executor.py::test_traceback_sync Start: 161, End: 143 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restart_sync_no_center distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53160), Worker: 127.0.0.1:53162 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53161), Worker: 127.0.0.1:53163 | |
| Start: 143, End: 161 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restart_sync distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53293), Worker: 127.0.0.1:53299 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53292), Worker: 127.0.0.1:53298 | |
| Start: 161, End: 179 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restart_fast distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53466), Worker: 127.0.0.1:53469 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 53467), Worker: 127.0.0.1:53468 | |
| Start: 179, End: 179 | |
| PASSED | |
| distributed/tests/test_executor.py::test_upload_file_sync Start: 179, End: 152 | |
| PASSED | |
| distributed/tests/test_executor.py::test_upload_file_exception_sync Start: 152, End: 170 | |
| PASSED | |
| distributed/tests/test_executor.py::test_sync_compute Start: 170, End: 152 | |
| PASSED | |
| distributed/tests/test_executor.py::test_start_is_idempotent Start: 152, End: 170 | |
| PASSED | |
| distributed/tests/test_executor.py::test_executor_with_scheduler distributed.scheduler - CRITICAL - Lost all workers | |
| PASSED | |
| distributed/tests/test_executor.py::test_bad_address SKIPPED | |
| distributed/tests/test_executor.py::test_badly_serialized_input_stderr Start: 167, End: 185 | |
| xfail | |
| distributed/tests/test_executor.py::test_repr_sync Start: 143, End: 167 | |
| PASSED | |
| distributed/tests/test_executor.py::test_broadcast Start: 167, End: 161 | |
| PASSED | |
| distributed/tests/test_executor.py::test_cancel Start: 161, End: 170 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_iterator_sync Start: 170, End: 188 | |
| PASSED | |
| distributed/tests/test_executor.py::test_Future_exception_sync FAILED | |
| distributed/tests/test_executor.py::test_persist Start: 188, End: 206 | |
| PASSED | |
| distributed/tests/test_executor.py::test_futures_of PASSED | |
| distributed/tests/test_executor.py::test_run_sync Start: 206, End: 206 | |
| PASSED | |
| distributed/tests/test_executor.py::test_diagnostic_ui Start: 206, End: 224 | |
| PASSED | |
| distributed/tests/test_executor.py::test_persist_get_sync Start: 224, End: 206 | |
| PASSED | |
| distributed/tests/test_executor.py::test_executor_num_fds Start: 206, End: 224 | |
| PASSED | |
| distributed/tests/test_executor.py::test_worker_aliases <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| PASSED | |
| distributed/tests/test_executor.py::test__scatter <- distributed/utils_test.py Start: 221, End: 221 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_robust_to_nested_missing_data <- distributed/utils_test.py Start: 221, End: 212 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restrictions_ip_port <- distributed/utils_test.py Start: 212, End: 212 | |
| PASSED | |
| distributed/tests/test_executor.py::test_get_with_non_list_key <- distributed/utils_test.py Start: 212, End: 212 | |
| PASSED | |
| distributed/tests/test_executor.py::test_recompute_released_key <- distributed/utils_test.py Start: 212, End: 203 | |
| PASSED | |
| distributed/tests/test_executor.py::test_get_releases_data <- distributed/utils_test.py Start: 203, End: 203 | |
| PASSED | |
| distributed/tests/test_executor.py::test_fast_kill <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55092), Worker: 127.0.0.1:55095 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55091), Worker: 127.0.0.1:55093 | |
| distributed.scheduler - CRITICAL - Lost all workers | |
| Start: 203, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_async_compute_with_scatter <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__cancel_collection <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_async_persist <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_remote_submit_on_Future <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_robust_to_missing_data <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_persist_get <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__as_completed <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_multiple_executors <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_aliases <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_garbage_collection <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_missing_worker <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_upload_file_exception <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_multiple_executors_restart <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55684), Worker: 127.0.0.1:55689 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55683), Worker: 127.0.0.1:55687 | |
| distributed.scheduler - CRITICAL - Lost all workers | |
| Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_future_type <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_run <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit_quotes <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restart <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55796), Worker: 127.0.0.1:55799 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 55798), Worker: 127.0.0.1:55801 | |
| distributed.scheduler - CRITICAL - Lost all workers | |
| Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_remote_scatter_gather <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_forget_simple <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_long_traceback <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_directed_scatter <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_start_with_scheduler <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_remote_scheduler <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_async_compute <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_naming <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_infinite_iterators <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_differnet_lengths <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_queue <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_waiting_data <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_upload_file <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_get <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_missing_data_heals <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_future <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_many_submits_spread_evenly <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_iterator <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_long_tasks_dont_trigger_timeout <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_exception_on_exception <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_nbytes_determines_worker <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_get_with_error <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__cancel_multi_client <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_on_futures_with_kwargs <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restrictions_submit <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_exceptions <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_forget_in_flight <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_errors_dont_block <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_garbage_collection_with_scatter <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_wait_on_collections <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gc <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__persist <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_Future_exception <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_scatter_hash <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_stress_1 <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restrictions_map <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_forget_complex <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_gather_strict <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_failed_worker_without_warning <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 56969), Worker: 127.0.0.1:56983 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 56970), Worker: 127.0.0.1:56974 | |
| distributed.scheduler - CRITICAL - Lost all workers | |
| Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_balance_tasks_by_stacks <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_long_error <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_restrictions_get <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_nbytes <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_wait <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_multi_garbage_collection <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_allow_restrictions <- distributed/utils_test.py SKIPPED | |
| distributed/tests/test_executor.py::test_forget_errors <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit_naming <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_traceback <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_repr <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_traceback_clean <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_map_quotes <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__cancel <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test__broadcast <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_dont_delete_recomputed_results <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_tokenize_on_futures <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_submit_then_get_with_Future <- distributed/utils_test.py Start: 215, End: 215 | |
| PASSED | |
| distributed/tests/test_executor.py::test_cleanup_after_broken_executor_connection <- distributed/utils_test.py Start: 215, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_badly_serialized_input <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_multi_executor <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_two_consecutive_executors_share_results <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_fatally_serialized_input <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_pragmatic_move_small_data_to_large_data <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_executor.py::test_compatible_map <- distributed/utils_test.py Start: 204, End: 204 | |
| PASSED | |
| distributed/tests/test_nanny.py::test_monitor_resources <- distributed/utils_test.py PASSED | |
| distributed/tests/test_nanny.py::test_nanny_process_failure <- distributed/utils_test.py PASSED | |
| distributed/tests/test_nanny.py::test_nanny <- distributed/utils_test.py PASSED | |
| distributed/tests/test_protocol.py::test_protocol PASSED | |
| distributed/tests/test_protocol.py::test_compression SKIPPED | |
| distributed/tests/test_protocol.py::test_small PASSED | |
| distributed/tests/test_s3.py::test_s3_file_access PASSED | |
| distributed/tests/test_s3.py::test_s3_file_info PASSED | |
| distributed/tests/test_s3.py::test_du PASSED | |
| distributed/tests/test_s3.py::test_s3_ls PASSED | |
| distributed/tests/test_s3.py::test_s3_ls_detail PASSED | |
| distributed/tests/test_s3.py::test_s3_glob PASSED | |
| distributed/tests/test_s3.py::test_get_list_of_summary_objects PASSED | |
| distributed/tests/test_s3.py::test_read_keys_from_bucket PASSED | |
| distributed/tests/test_s3.py::test_seek_delimiter SKIPPED | |
| distributed/tests/test_s3.py::test_read_s3_block PASSED | |
| distributed/tests/test_s3.py::test_read_text_sync Setting global dask scheduler to use distributed | |
| Start: 195, End: 207 | |
| PASSED | |
| distributed/tests/test_s3.py::test_pickle PASSED | |
| distributed/tests/test_s3.py::test_errors PASSED | |
| distributed/tests/test_s3.py::test_seek PASSED | |
| distributed/tests/test_s3.py::test_repr PASSED | |
| distributed/tests/test_s3.py::test_read_past_location PASSED | |
| distributed/tests/test_s3.py::test_read_csv_sync Setting global dask scheduler to use distributed | |
| Start: 207, End: 225 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes_block <- distributed/utils_test.py Start: 222, End: 215 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes_blocksize_on_large_data <- distributed/utils_test.py Start: 215, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes <- distributed/utils_test.py Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_text <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_csv_gzip <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes_blocksize_none <- distributed/utils_test.py Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes_lazy <- distributed/utils_test.py Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_bytes_delimited <- distributed/utils_test.py Start: 216, End: 216 | |
| PASSED | |
| distributed/tests/test_s3.py::test_read_csv <- distributed/utils_test.py Setting global dask scheduler to use distributed | |
| Start: 216, End: 217 | |
| FAILED | |
| distributed/tests/test_scheduler.py::test_heal PASSED | |
| distributed/tests/test_scheduler.py::test_heal_2 PASSED | |
| distributed/tests/test_scheduler.py::test_heal_restarts_leaf_tasks PASSED | |
| distributed/tests/test_scheduler.py::test_heal_culls PASSED | |
| distributed/tests/test_scheduler.py::test_update_state PASSED | |
| distributed/tests/test_scheduler.py::test_update_state_with_processing PASSED | |
| distributed/tests/test_scheduler.py::test_update_state_respects_data_in_memory PASSED | |
| distributed/tests/test_scheduler.py::test_update_state_supports_recomputing_released_results PASSED | |
| distributed/tests/test_scheduler.py::test_decide_worker_with_many_independent_leaves PASSED | |
| distributed/tests/test_scheduler.py::test_decide_worker_with_restrictions PASSED | |
| distributed/tests/test_scheduler.py::test_decide_worker_with_loose_restrictions PASSED | |
| distributed/tests/test_scheduler.py::test_decide_worker_without_stacks PASSED | |
| distributed/tests/test_scheduler.py::test_validate_state PASSED | |
| distributed/tests/test_scheduler.py::test_fill_missing_data PASSED | |
| distributed/tests/test_scheduler.py::test_dumps_function PASSED | |
| distributed/tests/test_scheduler.py::test_dumps_task PASSED | |
| distributed/tests/test_scheduler.py::test_file_descriptors_dont_leak distributed.scheduler - CRITICAL - Lost all workers | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_scheduler_as_center <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_worker_name <- distributed/utils_test.py PASSED | |
| distributed/tests/test_scheduler.py::test_coerce_address <- distributed/utils_test.py FAILED | |
| distributed/tests/test_scheduler.py::test_add_worker <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_scheduler <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_feed <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_rpc <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_self_aliases <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_multi_queues <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_remove_worker_from_scheduler <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_delete_callback <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_feed_setup_teardown <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_ready_add_worker <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_filtered_communication <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_delete_data <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_server <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_server_listens_to_other_ops <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_restart <- distributed/utils_test.py distributed.scheduler - CRITICAL - Lost all workers | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 54864), Worker: 127.0.0.1:54867 | |
| distributed.nanny - CRITICAL - Unable to unregister with center None. Nanny: ('127.0.0.1', 54863), Worker: 127.0.0.1:54865 | |
| distributed.scheduler - CRITICAL - Lost all workers | |
| Start: 43, End: 37 | |
| PASSED | |
| distributed/tests/test_scheduler.py::test_ready_remove_worker <- distributed/utils_test.py Start: 37, End: 37 | |
| PASSED | |
| distributed/tests/test_sizeof.py::test_base PASSED | |
| distributed/tests/test_sizeof.py::test_containers PASSED | |
| distributed/tests/test_sizeof.py::test_numpy PASSED | |
| distributed/tests/test_sizeof.py::test_pandas PASSED | |
| distributed/tests/test_utils.py::test_All PASSED | |
| distributed/tests/test_utils.py::test_sync PASSED | |
| distributed/tests/test_utils.py::test_sync_error PASSED | |
| distributed/tests/test_utils.py::test_sync_inactive_loop PASSED | |
| distributed/tests/test_utils.py::test_is_kernel PASSED | |
| distributed/tests/test_utils.py::test_ensure_ip PASSED | |
| distributed/tests/test_utils.py::test_truncate_exception PASSED | |
| distributed/tests/test_utils.py::test_get_traceback PASSED | |
| distributed/tests/test_utils.py::test_queue_to_iterator PASSED | |
| distributed/tests/test_utils.py::test_iterator_to_queue PASSED | |
| distributed/tests/test_utils.py::test_str_graph PASSED | |
| distributed/tests/test_utils.py::test_maybe_complex PASSED | |
| distributed/tests/test_utils.py::test_read_block PASSED | |
| distributed/tests/test_utils.py::test_seek_delimiter_endline PASSED | |
| distributed/tests/test_utils_test.py::test_cluster Start: 40, End: 47 | |
| PASSED | |
| distributed/tests/test_utils_test.py::test_gen_test <- distributed/utils_test.py PASSED | |
| distributed/tests/test_utils_test.py::test_gen_cluster <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_utils_test.py::test_gen_cluster_without_executor <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_worker.py::test_worker_ncores PASSED | |
| distributed/tests/test_worker.py::test_identity PASSED | |
| distributed/tests/test_worker.py::test_worker PASSED | |
| distributed/tests/test_worker.py::test_compute_who_has PASSED | |
| distributed/tests/test_worker.py::test_workers_update_center PASSED | |
| distributed/tests/test_worker.py::test_upload_file PASSED | |
| distributed/tests/test_worker.py::test_upload_egg PASSED | |
| distributed/tests/test_worker.py::test_broadcast PASSED | |
| distributed/tests/test_worker.py::test_worker_with_port_zero PASSED | |
| distributed/tests/test_worker.py::test_worker_waits_for_center_to_come_up PASSED | |
| distributed/tests/test_worker.py::test_worker_task <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_worker.py::test_worker_task_data <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| distributed/tests/test_worker.py::test_worker_task_bytes <- distributed/utils_test.py Start: 43, End: 43 | |
| PASSED | |
| ==================================== ERRORS ==================================== | |
| _______________ ERROR collecting distributed/tests/test_avro.py ________________ | |
| distributed/tests/test_avro.py:7: in <module> | |
| pytest.importorskip('hdfs3') | |
| ../../python/hdfs3/__init__.py:1: in <module> | |
| from .core import HDFileSystem, HDFile | |
| ../../python/hdfs3/core.py:12: in <module> | |
| from .lib import _lib | |
| ../../python/hdfs3/lib.py:11: in <module> | |
| _lib = ct.cdll.LoadLibrary('libhdfs3.so') | |
| ../../Documents/anaconda/lib/python3.4/ctypes/__init__.py:429: in LoadLibrary | |
| return self._dlltype(name) | |
| ../../Documents/anaconda/lib/python3.4/ctypes/__init__.py:351: in __init__ | |
| self._handle = _dlopen(self._name, mode) | |
| E OSError: dlopen(libhdfs3.so, 6): image not found | |
| _______________ ERROR collecting distributed/tests/test_hdfs.py ________________ | |
| distributed/tests/test_hdfs.py:20: in <module> | |
| pytest.importorskip('hdfs3') | |
| ../../python/hdfs3/__init__.py:1: in <module> | |
| from .core import HDFileSystem, HDFile | |
| ../../python/hdfs3/core.py:12: in <module> | |
| from .lib import _lib | |
| ../../python/hdfs3/lib.py:11: in <module> | |
| _lib = ct.cdll.LoadLibrary('libhdfs3.so') | |
| ../../Documents/anaconda/lib/python3.4/ctypes/__init__.py:429: in LoadLibrary | |
| return self._dlltype(name) | |
| ../../Documents/anaconda/lib/python3.4/ctypes/__init__.py:351: in __init__ | |
| self._handle = _dlopen(self._name, mode) | |
| E OSError: dlopen(libhdfs3.so, 6): image not found | |
| =================================== FAILURES =================================== | |
| __________________________ test_Future_exception_sync __________________________ | |
| loop = <tornado.platform.kqueue.KQueueIOLoop object at 0x1201cc5c0> | |
| capsys = <_pytest.capture.CaptureFixture object at 0x1201cc6a0> | |
| def test_Future_exception_sync(loop, capsys): | |
| with cluster() as (s, [a, b]): | |
| with Executor(('127.0.0.1', s['port']), loop=loop) as e: | |
| ensure_default_get(e) | |
| ensure_default_get(e) | |
| ensure_default_get(e) | |
| ensure_default_get(e) | |
| out, err = capsys.readouterr() | |
| > assert len(out.strip().split('\n')) == 1 | |
| E assert 2 == 1 | |
| E + where 2 = len(['Setting global dask scheduler to use distributed', 'Start: 188, End: 206']) | |
| E + where ['Setting global dask scheduler to use distributed', 'Start: 188, End: 206'] = <built-in method split of str object at 0x11a66ef30>('\n') | |
| E + where <built-in method split of str object at 0x11a66ef30> = 'Setting global dask scheduler to use distributed\nStart: 188, End: 206'.split | |
| E + where 'Setting global dask scheduler to use distributed\nStart: 188, End: 206' = <built-in method strip of str object at 0x11a7727b0>() | |
| E + where <built-in method strip of str object at 0x11a7727b0> = 'Setting global dask scheduler to use distributed\nStart: 188, End: 206\n'.strip | |
| distributed/tests/test_executor.py:1994: AssertionError | |
| ________________________________ test_read_csv _________________________________ | |
| def test_func(): | |
| import psutil | |
| startps = psutil.Process().num_fds() | |
| IOLoop.clear_instance() | |
| loop = IOLoop() | |
| loop.make_current() | |
| s, workers = loop.run_sync(lambda: start_cluster(ncores, | |
| Worker=Worker)) | |
| args = [s] + workers | |
| if executor: | |
| e = Executor((s.ip, s.port), loop=loop, start=False) | |
| loop.run_sync(e._start) | |
| args = [e] + args | |
| try: | |
| > loop.run_sync(lambda: cor(*args), timeout=timeout) | |
| distributed/utils_test.py:439: | |
| _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ | |
| self = <tornado.platform.kqueue.KQueueIOLoop object at 0x11b862da0> | |
| func = <function gen_cluster.<locals>._.<locals>.test_func.<locals>.<lambda> at 0x1244368c8> | |
| timeout = 60 | |
| def run_sync(self, func, timeout=None): | |
| """Starts the `IOLoop`, runs the given function, and stops the loop. | |
| The function must return either a yieldable object or | |
| ``None``. If the function returns a yieldable object, the | |
| `IOLoop` will run until the yieldable is resolved (and | |
| `run_sync()` will return the yieldable's result). If it raises | |
| an exception, the `IOLoop` will stop and the exception will be | |
| re-raised to the caller. | |
| The keyword-only argument ``timeout`` may be used to set | |
| a maximum duration for the function. If the timeout expires, | |
| a `TimeoutError` is raised. | |
| This method is useful in conjunction with `tornado.gen.coroutine` | |
| to allow asynchronous calls in a ``main()`` function:: | |
| @gen.coroutine | |
| def main(): | |
| # do stuff... | |
| if __name__ == '__main__': | |
| IOLoop.current().run_sync(main) | |
| .. versionchanged:: 4.3 | |
| Returning a non-``None``, non-yieldable value is now an error. | |
| """ | |
| future_cell = [None] | |
| def run(): | |
| try: | |
| result = func() | |
| if result is not None: | |
| from tornado.gen import convert_yielded | |
| result = convert_yielded(result) | |
| except Exception: | |
| future_cell[0] = TracebackFuture() | |
| future_cell[0].set_exc_info(sys.exc_info()) | |
| else: | |
| if is_future(result): | |
| future_cell[0] = result | |
| else: | |
| future_cell[0] = TracebackFuture() | |
| future_cell[0].set_result(result) | |
| self.add_future(future_cell[0], lambda future: self.stop()) | |
| self.add_callback(run) | |
| if timeout is not None: | |
| timeout_handle = self.add_timeout(self.time() + timeout, self.stop) | |
| self.start() | |
| if timeout is not None: | |
| self.remove_timeout(timeout_handle) | |
| if not future_cell[0].done(): | |
| > raise TimeoutError('Operation timed out after %s seconds' % timeout) | |
| E tornado.ioloop.TimeoutError: Operation timed out after 60 seconds | |
| ../../Documents/anaconda/lib/python3.4/site-packages/tornado/ioloop.py:452: TimeoutError | |
| _____________________________ test_coerce_address ______________________________ | |
| def test_func(): | |
| IOLoop.clear_instance() | |
| loop = IOLoop() | |
| loop.make_current() | |
| cor = gen.coroutine(func) | |
| try: | |
| > loop.run_sync(cor, timeout=timeout) | |
| distributed/utils_test.py:367: | |
| _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ | |
| self = <tornado.platform.kqueue.KQueueIOLoop object at 0x11b82ae10> | |
| func = <function test_coerce_address at 0x120717c80>, timeout = 10 | |
| def run_sync(self, func, timeout=None): | |
| """Starts the `IOLoop`, runs the given function, and stops the loop. | |
| The function must return either a yieldable object or | |
| ``None``. If the function returns a yieldable object, the | |
| `IOLoop` will run until the yieldable is resolved (and | |
| `run_sync()` will return the yieldable's result). If it raises | |
| an exception, the `IOLoop` will stop and the exception will be | |
| re-raised to the caller. | |
| The keyword-only argument ``timeout`` may be used to set | |
| a maximum duration for the function. If the timeout expires, | |
| a `TimeoutError` is raised. | |
| This method is useful in conjunction with `tornado.gen.coroutine` | |
| to allow asynchronous calls in a ``main()`` function:: | |
| @gen.coroutine | |
| def main(): | |
| # do stuff... | |
| if __name__ == '__main__': | |
| IOLoop.current().run_sync(main) | |
| .. versionchanged:: 4.3 | |
| Returning a non-``None``, non-yieldable value is now an error. | |
| """ | |
| future_cell = [None] | |
| def run(): | |
| try: | |
| result = func() | |
| if result is not None: | |
| from tornado.gen import convert_yielded | |
| result = convert_yielded(result) | |
| except Exception: | |
| future_cell[0] = TracebackFuture() | |
| future_cell[0].set_exc_info(sys.exc_info()) | |
| else: | |
| if is_future(result): | |
| future_cell[0] = result | |
| else: | |
| future_cell[0] = TracebackFuture() | |
| future_cell[0].set_result(result) | |
| self.add_future(future_cell[0], lambda future: self.stop()) | |
| self.add_callback(run) | |
| if timeout is not None: | |
| timeout_handle = self.add_timeout(self.time() + timeout, self.stop) | |
| self.start() | |
| if timeout is not None: | |
| self.remove_timeout(timeout_handle) | |
| if not future_cell[0].done(): | |
| > raise TimeoutError('Operation timed out after %s seconds' % timeout) | |
| E tornado.ioloop.TimeoutError: Operation timed out after 10 seconds | |
| ../../Documents/anaconda/lib/python3.4/site-packages/tornado/ioloop.py:452: TimeoutError | |
| ==== 3 failed, 281 passed, 15 skipped, 1 xfailed, 2 error in 169.98 seconds ==== | |
| [HANGS] |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment