Skip to content
This repository was archived by the owner on Jun 30, 2022. It is now read-only.

Commit 30c74e5

Browse files
aaltaygildea
authored andcommitted
Remove windmill host and port defaults from streaming worker
----Release Notes---- [] ------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=117002070
1 parent 668b7bb commit 30c74e5

1 file changed

Lines changed: 2 additions & 6 deletions

File tree

google/cloud/dataflow/worker/streamingworker.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -79,18 +79,14 @@ class StreamingWorker(object):
7979
# Maximum number of items to return in a GetWork request.
8080
MAX_GET_WORK_ITEMS = 100
8181

82-
# TODO(altay): Remove windmill default port and host.
83-
WINDMILL_DEFAULT_PORT = 12355
84-
8582
def __init__(self, properties):
8683
self.project_id = properties['project_id']
8784
self.job_id = properties['job_id']
8885
self.worker_id = properties['worker_id']
8986

9087
self.client_id = random.getrandbits(63)
91-
windmill_host = properties.get('windmill.host', self.worker_id)
92-
windmill_port = int(properties.get('windmill.hostport',
93-
StreamingWorker.WINDMILL_DEFAULT_PORT))
88+
windmill_host = properties['windmill.host']
89+
windmill_port = int(properties['windmill.grpc_port'])
9490
logging.info('Using gRPC to connect to Windmill at %s:%d.', windmill_host,
9591
windmill_port)
9692
self.windmill = WindmillClient(windmill_host, windmill_port)

0 commit comments

Comments
 (0)