-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathdlrpyc_server.py
42 lines (27 loc) · 865 Bytes
/
dlrpyc_server.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
'''
'''
import sys
import logging
import rpyc
from cli_servers_common import parser_
from rpycdl_lib.common import get_logger
from rpycdl_lib.dlrpyc_services import DLServiceMixin, server_builder
class DeepLearningService(DLServiceMixin, rpyc.Service):
'''DeepLearning RPyC Service'''
def main(argv=None):
'''Run DeepLearning service over RPyC.'''
desc = '{}{}'.format(__doc__, main.__doc__)
argv = sys.argv if argv is None else sys.argv.extend(argv)
# CLI parser
args = parser_(desc)
debug_flag = args.debug
gpus_on_system = args.ngpus
log = None
if debug_flag:
# print('DEBUGGING TF')
log = get_logger(__file__, level=logging.DEBUG)
server = server_builder(
DeepLearningService, log_obj=log, gpus_on_system=gpus_on_system)
server.start()
if __name__ == "__main__":
main()