vanvalenlab / kiosk-redis-consumer / 79

96%

push

travis-ci

writing output timestamp to Redis (#20)

* writing timestamp for Redis for output

* typo fix

* replace data processing functions with gRPC API client (#16)

* add gRPC client for data processing along with DP_HOST and DP_PORT as env vars

* remove processing.py and replace with ProcessClient calls in consumer

* update protos and pbs to enable StreamProcess with gRPC server along with grpc_client.stream_process to stream data in 64kB chunks to server

* utils.py 100% coverage but ignoring grpc_clients.py from coverage for now as grpcio_testing is poorly documented

* Add ZipFileConsumer and CONSUMER_TYPE to toggle between the two

* setting in_tensor_dtype dynamically based on model_name [if "f16" is in the model_name, cast to integer, not "half"]

* add env var GRPC_TIMEOUT (default 30) to set the timout for grpc requests

* process each key inside pre/postprocess functions.  Use while loop for gRPC retry for memory issue

* upgrade grpc version to 1.18.0

* add deploy stage to travis.yml

* typo fix

* adding output_timestamp to ZipFileConsumer and making everything PEP8 compliant

* avoiding the datetime.timestamp() function

* fixed typo

* fixed datetime typo

* PEP8 compliance

* fixing whitespace issue

* change timestamp to milliseconds

* typo fix

* adding output_timestamp to ZipFileConsumer and making everything PEP8 compliant

* avoiding the datetime.timestamp() function

* fixed typo

* fixed datetime typo

* PEP8 compliance

* fixing whitespace issue

* change timestamp to milliseconds

* simplifying output_timestamp computation

2 of 2 new or added lines in 1 file covered. (100.0%)

455 of 557 relevant lines covered (81.69%)

2.45 hits per line