##// END OF EJS Templates
Robustness fixes in test suite machinery....
Robustness fixes in test suite machinery. Added a module-level INSTALLED flag, which can be set to false if the test suite is being run in-place (without ipython having been installed at all). This is because how we call and import things must be done differently depending on whether the code is installed or is being run in-place. The only ones that can know this reliably are the entry-point scripts, so those are responsible for setting this flag. Also made the code that validates ipython in subprocesses report errors better, by checking stderr for errors before validating stdout output, as anything on stderr will be likely informative of the real problem.

File last commit:

r2306:cc803e0b
r2494:c8938204
Show More
asyncclient.py
42 lines | 1.5 KiB | text/x-python | PythonLexer
#!/usr/bin/env python
# encoding: utf-8
"""Asynchronous clients for the IPython controller.
This module has clients for using the various interfaces of the controller
in a fully asynchronous manner. This means that you will need to run the
Twisted reactor yourself and that all methods of the client classes return
deferreds to the result.
The main methods are are `get_*_client` and `get_client`.
"""
#-----------------------------------------------------------------------------
# Copyright (C) 2008-2009 The IPython Development Team
#
# Distributed under the terms of the BSD License. The full license is in
# the file COPYING, distributed as part of this software.
#-----------------------------------------------------------------------------
#-----------------------------------------------------------------------------
# Imports
#-----------------------------------------------------------------------------
from IPython.kernel import codeutil
from IPython.kernel.clientconnector import (
AsyncClientConnector,
AsyncCluster
)
# Other things that the user will need
from IPython.kernel.task import MapTask, StringTask
from IPython.kernel.error import CompositeError
#-----------------------------------------------------------------------------
# Code
#-----------------------------------------------------------------------------
_client_tub = AsyncClientConnector()
get_multiengine_client = _client_tub.get_multiengine_client
get_task_client = _client_tub.get_task_client
get_client = _client_tub.get_client