wolframclient.utils package

Submodules

wolframclient.utils.api module

wolframclient.utils.asyncio module

wolframclient.utils.asyncio.get_event_loop(loop=None)

wolframclient.utils.asyncio.run_all(args, **opts)

wolframclient.utils.asyncio.run_in_loop(cor, loop=None)

wolframclient.utils.asyncio.silence(*exceptions)

wolframclient.utils.datastructures module

class wolframclient.utils.datastructures.Association

Bases: collections.OrderedDict

A OrderedDict that serializes to an Association

class wolframclient.utils.datastructures.Settings

Bases: dict

Dictionary subclass enabling attribute lookup/assignment of keys/values.

For example:

>>> m = Settings({'foo': 'bar'})
>>> m.foo
'bar'
>>> m.foo = 'not bar'
>>> m['foo']
'not bar'

Settings objects also provide .first() which acts like .get() but accepts multiple keys as arguments, and returns the value of the first hit, e.g.:

>>> m = Settings({'foo': 'bar', 'biz': 'baz'})
>>> m.first('wrong', 'incorrect', 'foo', 'biz')
'bar'

wolframclient.utils.debug module

wolframclient.utils.debug.echo(x)

wolframclient.utils.debug.print_elapsed_time(viewfunc)

wolframclient.utils.debug.repeated_timing(function, *args, **opts)

wolframclient.utils.debug.timed(function)

wolframclient.utils.debug.timed_repeated(N=30)

wolframclient.utils.decorators module

class wolframclient.utils.decorators.cached_property(func, name=None)

Bases: object

Decorator that converts a method with a single self argument into a property cached on the instance.

Optional name argument allows you to make cached properties of other methods. (e.g. url = cached_property(get_absolute_url, name=’url’) )

wolframclient.utils.decorators.decorate(*func)

wolframclient.utils.decorators.to_dict(fn)

wolframclient.utils.decorators.to_tuple(fn)

wolframclient.utils.dispatch module

class wolframclient.utils.dispatch.Dispatch

Bases: object

A method dispatcher class allowing for multiple implementations of a function. Each implementation is associated to a specific input type.

Implementations are registered with the annotation dispatch().

The Dispatch class is callable, it behaves as a function that uses the implementation corresponding to the input parameter.

When a type is a subtype, the type and its parents are checked in the order given by __mro__ (method resolution order).

Example: method resolve() applied to an instance of collections.OrderedDict, check for the first implementation to match with collections.OrderedDict, then with dict, and ultimately to object.

Once the mapping is determined, it is cached for later use.

as_method()

Return the dispatch as a class method.

Create a new dispatcher:

dispatch = Dispatcher()

Use the dispatcher as a class method:

class MyClass(object):
    myMethod = dispatch.as_method()

Call the class method:

o = MyClass()
o.myMethod(arg, *args, **kwargs)

clear()

Reset the dispatcher to its initial state.

clear_cache()

default_function(*args, **opts)

Ultimately called when no type was found.

dispatch(*args, **opts)

Annotate a function and map it to a given set of type(s).

Declare an implementation to use on bytearray input:

@dispatcher.dispatch(bytearray)
def my_func(...)

The default implementation is associated with object. Set a default:

@dispatcher.dispatch(object)
def my_default_func(...)

A tuple can be used as input to associate more than one type with a function. Declare a function used for both bytes and bytearray:

@dispatcher.dispatch((bytes, bytearray))
def my_func(...)

Implementation must be unique. By default, registering the same combination of types will raise an error. Set replace_existing to True to update the current mapping. Or, set keep_existing to True to ignore duplicate registration and keep the existing mapping.

register(function, types=<class 'object'>, keep_existing=False, replace_existing=False)

Equivalent to annotation dispatch() but as a function.

resolve(arg)

Return the implementation better matching the type the argument type.

unregister(types=<class 'object'>)

Remove implementations associated with types.

update(dispatch, **opts)

Update current mapping with the one from dispatch.

dispatch can be a Dispatch instance or a dict. **opts are passed to register()

validate_types(types)

wolframclient.utils.encoding module

wolframclient.utils.encoding.concatenate_bytes()

Concatenate any number of bytes objects.

The bytes whose method is called is inserted in between each pair.

The result is returned as a new bytes object.

Example: b’.’.join([b’ab’, b’pq’, b’rs’]) -> b’ab.pq.rs’.

wolframclient.utils.encoding.force_bytes(s, encoding='utf-8', errors='strict')

If strings_only is True, don’t convert (some) non-string-like objects.

wolframclient.utils.encoding.force_text(s, encoding='utf-8', errors='strict')

Similar to smart_text, except that lazy instances are resolved to strings, rather than kept as lazy objects.

If strings_only is True, don’t convert (some) non-string-like objects.

wolframclient.utils.encoding.safe_force_text(obj)

wolframclient.utils.externalevaluate module

wolframclient.utils.externalevaluate.EvaluationEnvironment(code, session_data={}, constants=None, **extra)

class wolframclient.utils.externalevaluate.SideEffectSender(level=0)

Bases: logging.Handler

emit(record)

Do whatever it takes to actually log the specified logging record.

This version is intended to be implemented by subclasses and so raises a NotImplementedError.

class wolframclient.utils.externalevaluate.SocketWriter(socket)

Bases: object

write(bytes)

class wolframclient.utils.externalevaluate.StdoutProxy(stream)

Bases: object

clear()

flush()

keep_listening

Provide a convenient way to build objects representing arbitrary Wolfram Language expressions through the use of attributes.

This class is conveniently instantiated at startup as wl, Global and System. It should be instantiated only to represent many symbols belonging to the same specific context.

Example:

>>> dev = WLSymbolFactory('Developer')
>>> dev.PackedArrayQ
Developer`PackedArrayQ

Alternative:

>>> wl.Developer.PackedArrayQ
Developer`PackedArrayQ

send_lines(*lines)

send_side_effect(expr)

write(message)

wolframclient.utils.externalevaluate.evaluate_message(input=None, return_type=None, args=None, **opts)

wolframclient.utils.externalevaluate.execute_from_file(path, *args, **opts)

wolframclient.utils.externalevaluate.execute_from_string(code, globals={}, **opts)

wolframclient.utils.externalevaluate.handle_message(socket, evaluate_message=<function evaluate_message>, consumer=None)

wolframclient.utils.externalevaluate.start_zmq_instance(port=None, write_to_stdout=True, **opts)

wolframclient.utils.externalevaluate.start_zmq_loop(message_limit=inf, redirect_stdout=True, export_kwargs={'allow_external_objects': True, 'target_format': 'wxf'}, evaluate_message=<function evaluate_message>, exception_class=None, consumer=None, **opts)

wolframclient.utils.functional module

wolframclient.utils.functional.composition(*functions)

wolframclient.utils.functional.first(iterable, default=None)

wolframclient.utils.functional.flatten(*args)

wolframclient.utils.functional.identity(x)

wolframclient.utils.functional.is_iterable(obj, exclude_list=(<class 'str'>, ))

wolframclient.utils.functional.iterate(*args)

wolframclient.utils.functional.last(iterable, default=None)

wolframclient.utils.functional.partition(iterable, n)

Yield successive n-sized chunks from l.

wolframclient.utils.functional.riffle(iterable, separator)

wolframclient.utils.functional.to_iterable(obj, exclude_list=(<class 'str'>, ))

wolframclient.utils.importutils module

class wolframclient.utils.importutils.API(importer=<function safe_import_string>, **mapping)

Bases: object

items()

keys()

values()

wolframclient.utils.importutils.import_string(dotted_path)

Import a dotted module path and return the attribute/class designated by the last name in the path. Raise ImportError if the import failed.

wolframclient.utils.importutils.module_path(module, *args)

wolframclient.utils.importutils.safe_import_string(f)

wolframclient.utils.importutils.safe_import_string_and_call(f, *args, **kw)

wolframclient.utils.json module

wolframclient.utils.logger module

wolframclient.utils.logger.setup_logging_to_file(path, level=None)

Setup a basic Python logging configuration to a given file.

wolframclient.utils.logger.str_trim(o, max_char=80)

Return the string representation of an object, trimmed to keep up to max_char characters.

wolframclient.utils.packedarray module

class wolframclient.utils.packedarray.PackedArray

Bases: numpy.ndarray

Wrapper class on top of NymPy ndarray used to preserve packed arrays when round-tripping them.

wolframclient.utils.require module

wolframclient.utils.require.installed_modules()

wolframclient.utils.require.missing_requirements(*modules)

wolframclient.utils.require.require(*modules)

wolframclient.utils.require.require_module(*modules)

wolframclient.utils.six module

wolframclient.utils.tests module

class wolframclient.utils.tests.TestCase(methodName='runTest')

Bases: unittest.case.TestCase

wolframclient.utils.tests.path_to_file_in_data_dir(*args)

wolframclient.utils.url module

wolframclient.utils.url.evaluation_api_url(server)

wolframclient.utils.url.url_join(*fragments)

Join fragments of a URL, dealing with slashes.

wolframclient.utils.url.user_api_url(server, api)

Build an API URL from a user name and an API id.

Module contents