sharpie.webserver.experiment.consumer_helpers

Helper classes and functions for WebSocket consumers.

Functions

decode_data(…)

Decode data that may contain LZMA-compressed pickled arrays.

Classes

RunConsumerHelpers()

Synchronous helper methods for RunConsumer.

class sharpie.webserver.experiment.consumer_helpers.RunConsumerHelpers

Synchronous helper methods for RunConsumer.

These methods perform database operations and are wrapped by async methods in RunConsumer using database_sync_to_async.

sharpie.webserver.experiment.consumer_helpers.decode_data(data)

Decode data that may contain LZMA-compressed pickled arrays.

Recursively processes dictionaries and lists, converting any compressed arrays back to numpy arrays.