B F.\@sbddlmZmZmZddlmZddlmZmZddl m Z Gddde Z Gdd d e eZ d S) )print_functiondivisionabsolute_import)IOLoop)ServerConnectionPool) get_versionsc@seZdZdZdddZdS)Nodez8 Base class for nodes in a distributed cluster. TNcCs&|p t|_t|||||d|_dS)N)limit deserialize serializers deserializersconnection_args)rZcurrentio_looprZrpc)selfconnection_limitr rrrrr/lib/python3.7/site-packages/distributed/node.py__init__s z Node.__init__)r TNNNN)__name__ __module__ __qualname____doc__rrrrrr sr c@s$eZdZdZd ddZd ddZdS) ServerNodez? Base class for server nodes in a distributed cluster. NTc Cs4tj|||||||dtj||||||jddS)N)r rrrrr)handlersstream_handlersrr r)r rrr) rrrrr rrrrrrrr"szServerNode.__init__cCs t|dS)N)packages)r )rZcommrrrrversions1szServerNode.versions)NNrTNNNN)NN)rrrrrr rrrrrs  rN)Z __future__rrrZtornado.iolooprZcorerrr r objectr rrrrrs