You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/02/15 01:05:46 UTC
[1/4] beam git commit: [BEAM-1473] Remove unused windmill proto from
python sdk
Repository: beam
Updated Branches:
refs/heads/master 0d3389a20 -> 2685ba528
http://git-wip-us.apache.org/repos/asf/beam/blob/88b2d9b2/sdks/python/apache_beam/internal/windmill_service_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/internal/windmill_service_pb2.py b/sdks/python/apache_beam/internal/windmill_service_pb2.py
deleted file mode 100644
index b26fb63..0000000
--- a/sdks/python/apache_beam/internal/windmill_service_pb2.py
+++ /dev/null
@@ -1,164 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-# Generated by the protocol buffer compiler. DO NOT EDIT!
-# source: windmill_service.proto
-
-import sys
-_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
-from google.protobuf import descriptor as _descriptor
-from google.protobuf import message as _message
-from google.protobuf import reflection as _reflection
-from google.protobuf import symbol_database as _symbol_database
-from google.protobuf import descriptor_pb2
-# @@protoc_insertion_point(imports)
-
-_sym_db = _symbol_database.Default()
-
-
-import windmill_pb2 as windmill__pb2
-
-
-DESCRIPTOR = _descriptor.FileDescriptor(
- name='windmill_service.proto',
- package='google.dataflow.windmillservice.v1alpha1',
- syntax='proto2',
- serialized_pb=_b('\n\x16windmill_service.proto\x12(google.dataflow.windmillservice.v1alpha1\x1a\x0ewindmill.proto2\xf9\x02\n\x1c\x43loudWindmillServiceV1Alpha1\x12>\n\x07GetWork\x12\x18.windmill.GetWorkRequest\x1a\x19.windmill.GetWorkResponse\x12>\n\x07GetData\x12\x18.windmill.GetDataRequest\x1a\x19.windmill.GetDataResponse\x12G\n\nCommitWork\x12\x1b.windmill.CommitWorkRequest\x1a\x1c.windmill.CommitWorkResponse\x12\x44\n\tGetConfig\x12\x1a.windmill.GetConfigRequest\x1a\x1b.windmill.GetConfigResponse\x12J\n\x0bReportStats\x12\x1c.windmill.ReportStatsRequest\x1a\x1d.windmill.ReportStatsResponseB7\n5com.apache_beam.sdk.runners.worker.windmill')
- ,
- dependencies=[windmill__pb2.DESCRIPTOR,])
-_sym_db.RegisterFileDescriptor(DESCRIPTOR)
-
-
-
-
-
-DESCRIPTOR.has_options = True
-DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n5com.apache_beam.sdk.runners.worker.windmill'))
-from grpc.beta import implementations as beta_implementations
-from grpc.beta import interfaces as beta_interfaces
-from grpc.framework.common import cardinality
-from grpc.framework.interfaces.face import utilities as face_utilities
-
-
-class BetaCloudWindmillServiceV1Alpha1Servicer(object):
- """The Cloud Windmill Service API used by GCE to acquire and process streaming
- Dataflow work.
- """
- def GetWork(self, request, context):
- """Gets streaming Dataflow work.
- """
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
- def GetData(self, request, context):
- """Gets data from Windmill.
- """
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
- def CommitWork(self, request, context):
- """Commits previously acquired work.
- """
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
- def GetConfig(self, request, context):
- """Gets dependant configuration from windmill.
- """
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
- def ReportStats(self, request, context):
- """Reports stats to Windmill.
- """
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
-
-
-class BetaCloudWindmillServiceV1Alpha1Stub(object):
- """The Cloud Windmill Service API used by GCE to acquire and process streaming
- Dataflow work.
- """
- def GetWork(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- """Gets streaming Dataflow work.
- """
- raise NotImplementedError()
- GetWork.future = None
- def GetData(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- """Gets data from Windmill.
- """
- raise NotImplementedError()
- GetData.future = None
- def CommitWork(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- """Commits previously acquired work.
- """
- raise NotImplementedError()
- CommitWork.future = None
- def GetConfig(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- """Gets dependant configuration from windmill.
- """
- raise NotImplementedError()
- GetConfig.future = None
- def ReportStats(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- """Reports stats to Windmill.
- """
- raise NotImplementedError()
- ReportStats.future = None
-
-
-def beta_create_CloudWindmillServiceV1Alpha1_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
- request_deserializers = {
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'CommitWork'): windmill__pb2.CommitWorkRequest.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetConfig'): windmill__pb2.GetConfigRequest.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetData'): windmill__pb2.GetDataRequest.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetWork'): windmill__pb2.GetWorkRequest.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'ReportStats'): windmill__pb2.ReportStatsRequest.FromString,
- }
- response_serializers = {
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'CommitWork'): windmill__pb2.CommitWorkResponse.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetConfig'): windmill__pb2.GetConfigResponse.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetData'): windmill__pb2.GetDataResponse.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetWork'): windmill__pb2.GetWorkResponse.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'ReportStats'): windmill__pb2.ReportStatsResponse.SerializeToString,
- }
- method_implementations = {
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'CommitWork'): face_utilities.unary_unary_inline(servicer.CommitWork),
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetConfig'): face_utilities.unary_unary_inline(servicer.GetConfig),
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetData'): face_utilities.unary_unary_inline(servicer.GetData),
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetWork'): face_utilities.unary_unary_inline(servicer.GetWork),
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'ReportStats'): face_utilities.unary_unary_inline(servicer.ReportStats),
- }
- server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
- return beta_implementations.server(method_implementations, options=server_options)
-
-
-def beta_create_CloudWindmillServiceV1Alpha1_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
- request_serializers = {
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'CommitWork'): windmill__pb2.CommitWorkRequest.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetConfig'): windmill__pb2.GetConfigRequest.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetData'): windmill__pb2.GetDataRequest.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetWork'): windmill__pb2.GetWorkRequest.SerializeToString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'ReportStats'): windmill__pb2.ReportStatsRequest.SerializeToString,
- }
- response_deserializers = {
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'CommitWork'): windmill__pb2.CommitWorkResponse.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetConfig'): windmill__pb2.GetConfigResponse.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetData'): windmill__pb2.GetDataResponse.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'GetWork'): windmill__pb2.GetWorkResponse.FromString,
- ('google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', 'ReportStats'): windmill__pb2.ReportStatsResponse.FromString,
- }
- cardinalities = {
- 'CommitWork': cardinality.Cardinality.UNARY_UNARY,
- 'GetConfig': cardinality.Cardinality.UNARY_UNARY,
- 'GetData': cardinality.Cardinality.UNARY_UNARY,
- 'GetWork': cardinality.Cardinality.UNARY_UNARY,
- 'ReportStats': cardinality.Cardinality.UNARY_UNARY,
- }
- stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
- return beta_implementations.dynamic_stub(channel, 'google.dataflow.windmillservice.v1alpha1.CloudWindmillServiceV1Alpha1', cardinalities, options=stub_options)
-# @@protoc_insertion_point(module_scope)
http://git-wip-us.apache.org/repos/asf/beam/blob/88b2d9b2/sdks/python/run_pylint.sh
----------------------------------------------------------------------
diff --git a/sdks/python/run_pylint.sh b/sdks/python/run_pylint.sh
index fc7b244..cfb3a39 100755
--- a/sdks/python/run_pylint.sh
+++ b/sdks/python/run_pylint.sh
@@ -28,8 +28,6 @@ set -o pipefail
# Following generated files are excluded from lint checks.
EXCLUDED_GENERATED_FILES=(
-"apache_beam/internal/windmill_pb2.py"
-"apache_beam/internal/windmill_service_pb2.py"
"apache_beam/internal/clients/bigquery/bigquery_v2_client.py"
"apache_beam/internal/clients/bigquery/bigquery_v2_messages.py"
"apache_beam/internal/clients/dataflow/dataflow_v1b3_client.py"
[2/4] beam git commit: [BEAM-1473] Remove unused windmill proto from
python sdk
Posted by al...@apache.org.
http://git-wip-us.apache.org/repos/asf/beam/blob/88b2d9b2/sdks/python/apache_beam/internal/windmill_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/internal/windmill_pb2.py b/sdks/python/apache_beam/internal/windmill_pb2.py
deleted file mode 100644
index c9a5c4e..0000000
--- a/sdks/python/apache_beam/internal/windmill_pb2.py
+++ /dev/null
@@ -1,2278 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-# Generated by the protocol buffer compiler. DO NOT EDIT!
-# source: windmill.proto
-
-import sys
-_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
-from google.protobuf import descriptor as _descriptor
-from google.protobuf import message as _message
-from google.protobuf import reflection as _reflection
-from google.protobuf import symbol_database as _symbol_database
-from google.protobuf import descriptor_pb2
-# @@protoc_insertion_point(imports)
-
-_sym_db = _symbol_database.Default()
-
-
-
-
-DESCRIPTOR = _descriptor.FileDescriptor(
- name='windmill.proto',
- package='windmill',
- syntax='proto2',
- serialized_pb=_b('\n\x0ewindmill.proto\x12\x08windmill\"R\n\x07Message\x12\'\n\ttimestamp\x18\x01 \x02(\x03:\x14-9223372036854775808\x12\x0c\n\x04\x64\x61ta\x18\x02 \x02(\x0c\x12\x10\n\x08metadata\x18\x03 \x01(\x0c\"\xbf\x01\n\x05Timer\x12\x0b\n\x03tag\x18\x01 \x02(\x0c\x12\'\n\ttimestamp\x18\x02 \x01(\x03:\x14-9223372036854775808\x12-\n\x04type\x18\x03 \x01(\x0e\x32\x14.windmill.Timer.Type:\tWATERMARK\x12\x14\n\x0cstate_family\x18\x04 \x01(\t\";\n\x04Type\x12\r\n\tWATERMARK\x10\x00\x12\x0c\n\x08REALTIME\x10\x01\x12\x16\n\x12\x44\x45PENDENT_REALTIME\x10\x02\"X\n\x12InputMessageBundle\x12\x1d\n\x15source_computation_id\x18\x01 \x02(\t\x12#\n\x08messages\x18\x02 \x03(\x0b\x32\x11.windmill.Message\"r\n\x12KeyedMessageBundle\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\x14\n\x0csharding_key\x18\x04 \x01(\x06\x12#\n\x08messages\x18\x02 \x03(\x0b\x32\x11.windmill.Message\x12\x14\n\x0cmessages_ids\x18\x03 \x03(\x0c\"\x87\x01\n\x13OutputMessageBundle\x12\"\n\x1a\x64\x65stination_computation_id\
x18\x01 \x01(\t\x12\x1d\n\x15\x64\x65stination_stream_id\x18\x03 \x01(\t\x12-\n\x07\x62undles\x18\x02 \x03(\x0b\x32\x1c.windmill.KeyedMessageBundle\"t\n\x13PubSubMessageBundle\x12\r\n\x05topic\x18\x01 \x02(\t\x12#\n\x08messages\x18\x02 \x03(\x0b\x32\x11.windmill.Message\x12\x17\n\x0ftimestamp_label\x18\x03 \x01(\t\x12\x10\n\x08id_label\x18\x04 \x01(\t\".\n\x0bTimerBundle\x12\x1f\n\x06timers\x18\x01 \x03(\x0b\x32\x0f.windmill.Timer\">\n\x05Value\x12\'\n\ttimestamp\x18\x01 \x02(\x03:\x14-9223372036854775808\x12\x0c\n\x04\x64\x61ta\x18\x02 \x02(\x0c\"M\n\x08TagValue\x12\x0b\n\x03tag\x18\x01 \x02(\x0c\x12\x1e\n\x05value\x18\x02 \x01(\x0b\x32\x0f.windmill.Value\x12\x14\n\x0cstate_family\x18\x03 \x01(\t\"\xdb\x01\n\x07TagList\x12\x0b\n\x03tag\x18\x01 \x02(\x0c\x12+\n\rend_timestamp\x18\x02 \x01(\x03:\x14-9223372036854775808\x12\x1f\n\x06values\x18\x03 \x03(\x0b\x32\x0f.windmill.Value\x12\x14\n\x0cstate_family\x18\x04 \x01(\t\x12\x15\n\rrequest_token\x18\x07 \x01(\x0c\x12\x1a\n\x12\x63onti
nuation_token\x18\x05 \x01(\x0c\x12,\n\x0f\x66\x65tch_max_bytes\x18\x06 \x01(\x03:\x13\x39\x32\x32\x33\x33\x37\x32\x30\x33\x36\x38\x35\x34\x37\x37\x35\x38\x30\x37\",\n\x0cGlobalDataId\x12\x0b\n\x03tag\x18\x01 \x02(\t\x12\x0f\n\x07version\x18\x02 \x02(\x0c\"k\n\nGlobalData\x12\'\n\x07\x64\x61ta_id\x18\x01 \x02(\x0b\x32\x16.windmill.GlobalDataId\x12\x10\n\x08is_ready\x18\x02 \x01(\x08\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\x12\x14\n\x0cstate_family\x18\x04 \x01(\t\"I\n\x0bSourceState\x12\r\n\x05state\x18\x01 \x01(\x0c\x12\x14\n\x0c\x66inalize_ids\x18\x02 \x03(\x06\x12\x15\n\ronly_finalize\x18\x03 \x01(\x08\"Y\n\rWatermarkHold\x12\x0b\n\x03tag\x18\x01 \x02(\x0c\x12\x16\n\ntimestamps\x18\x02 \x03(\x03\x42\x02\x10\x01\x12\r\n\x05reset\x18\x03 \x01(\x08\x12\x14\n\x0cstate_family\x18\x04 \x01(\t\"\xd4\x02\n\x08WorkItem\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\x12\n\nwork_token\x18\x02 \x02(\x06\x12\x14\n\x0csharding_key\x18\t \x01(\x06\x12\x13\n\x0b\x63\x61\x63he_token\x18\x07 \x01(\x06\x
12\x35\n\x0fmessage_bundles\x18\x03 \x03(\x0b\x32\x1c.windmill.InputMessageBundle\x12%\n\x06timers\x18\x04 \x01(\x0b\x32\x15.windmill.TimerBundle\x12<\n\x1cglobal_data_id_notifications\x18\x05 \x03(\x0b\x32\x16.windmill.GlobalDataId\x12+\n\x0csource_state\x18\x06 \x01(\x0b\x32\x15.windmill.SourceState\x12\x33\n\x15output_data_watermark\x18\x08 \x01(\x03:\x14-9223372036854775808\"\xc6\x01\n\x14\x43omputationWorkItems\x12\x16\n\x0e\x63omputation_id\x18\x01 \x02(\t\x12 \n\x04work\x18\x02 \x03(\x0b\x32\x12.windmill.WorkItem\x12\x32\n\x14input_data_watermark\x18\x03 \x01(\x03:\x14-9223372036854775808\x12@\n\"dependent_realtime_input_watermark\x18\x04 \x01(\x03:\x14-9223372036854775808\"\x8d\x01\n\x0eGetWorkRequest\x12\x11\n\tclient_id\x18\x01 \x02(\x06\x12\x11\n\tworker_id\x18\x04 \x01(\t\x12\x0e\n\x06job_id\x18\x05 \x01(\t\x12\x1d\n\tmax_items\x18\x02 \x01(\x03:\n4294967295\x12&\n\tmax_bytes\x18\x03 \x01(\x03:\x13\x39\x32\x32\x33\x33\x37\x32\x30\x33\x36\x38\x35\x34\x37\x37\x35\x38\x30\x
37\"?\n\x0fGetWorkResponse\x12,\n\x04work\x18\x01 \x03(\x0b\x32\x1e.windmill.ComputationWorkItems\"\xdf\x01\n\x13KeyedGetDataRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\x12\n\nwork_token\x18\x02 \x02(\x06\x12\x14\n\x0csharding_key\x18\x06 \x01(\x06\x12+\n\x0fvalues_to_fetch\x18\x03 \x03(\x0b\x32\x12.windmill.TagValue\x12)\n\x0elists_to_fetch\x18\x04 \x03(\x0b\x32\x11.windmill.TagList\x12\x39\n\x18watermark_holds_to_fetch\x18\x05 \x03(\x0b\x32\x17.windmill.WatermarkHold\"d\n\x19\x43omputationGetDataRequest\x12\x16\n\x0e\x63omputation_id\x18\x01 \x02(\t\x12/\n\x08requests\x18\x02 \x03(\x0b\x32\x1d.windmill.KeyedGetDataRequest\"\xce\x01\n\x0eGetDataRequest\x12\x0e\n\x06job_id\x18\x04 \x01(\t\x12\x35\n\x08requests\x18\x01 \x03(\x0b\x32#.windmill.ComputationGetDataRequest\x12?\n\x1aglobal_data_fetch_requests\x18\x03 \x03(\x0b\x32\x1b.windmill.GlobalDataRequest\x12\x34\n\x14global_data_to_fetch\x18\x02 \x03(\x0b\x32\x16.windmill.GlobalDataId\"\xab\x01\n\x14KeyedGetDataResponse\x12\x0b\
n\x03key\x18\x01 \x02(\x0c\x12\x0e\n\x06\x66\x61iled\x18\x02 \x01(\x08\x12\"\n\x06values\x18\x03 \x03(\x0b\x32\x12.windmill.TagValue\x12 \n\x05lists\x18\x04 \x03(\x0b\x32\x11.windmill.TagList\x12\x30\n\x0fwatermark_holds\x18\x05 \x03(\x0b\x32\x17.windmill.WatermarkHold\"b\n\x1a\x43omputationGetDataResponse\x12\x16\n\x0e\x63omputation_id\x18\x01 \x02(\t\x12,\n\x04\x64\x61ta\x18\x02 \x03(\x0b\x32\x1e.windmill.KeyedGetDataResponse\"p\n\x0fGetDataResponse\x12\x32\n\x04\x64\x61ta\x18\x01 \x03(\x0b\x32$.windmill.ComputationGetDataResponse\x12)\n\x0bglobal_data\x18\x02 \x03(\x0b\x32\x14.windmill.GlobalData\"\xbd\x01\n\x07\x43ounter\x12\x0c\n\x04name\x18\x01 \x01(\t\x12$\n\x04kind\x18\x02 \x01(\x0e\x32\x16.windmill.Counter.Kind\x12\x15\n\rdouble_scalar\x18\x03 \x01(\x01\x12\x12\n\nint_scalar\x18\x04 \x01(\x03\x12\x12\n\nmean_count\x18\x06 \x01(\x03\x12\x12\n\ncumulative\x18\x07 \x01(\x08\"+\n\x04Kind\x12\x07\n\x03SUM\x10\x00\x12\x07\n\x03MAX\x10\x01\x12\x07\n\x03MIN\x10\x02\x12\x08\n\x04MEA
N\x10\x03\"\x8d\x01\n\x11GlobalDataRequest\x12\'\n\x07\x64\x61ta_id\x18\x01 \x02(\x0b\x32\x16.windmill.GlobalDataId\x12\x39\n\x1c\x65xistence_watermark_deadline\x18\x02 \x01(\x03:\x13\x39\x32\x32\x33\x33\x37\x32\x30\x33\x36\x38\x35\x34\x37\x37\x35\x38\x30\x37\x12\x14\n\x0cstate_family\x18\x03 \x01(\t\"\xa4\x05\n\x15WorkItemCommitRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\x12\n\nwork_token\x18\x02 \x02(\x06\x12\x14\n\x0csharding_key\x18\x0f \x01(\x06\x12\x36\n\x0foutput_messages\x18\x03 \x03(\x0b\x32\x1d.windmill.OutputMessageBundle\x12\x36\n\x0fpubsub_messages\x18\x07 \x03(\x0b\x32\x1d.windmill.PubSubMessageBundle\x12&\n\routput_timers\x18\x04 \x03(\x0b\x32\x0f.windmill.Timer\x12)\n\rvalue_updates\x18\x05 \x03(\x0b\x32\x12.windmill.TagValue\x12\'\n\x0clist_updates\x18\x06 \x03(\x0b\x32\x11.windmill.TagList\x12*\n\x0f\x63ounter_updates\x18\x08 \x03(\x0b\x32\x11.windmill.Counter\x12\x39\n\x14global_data_requests\x18\x0b \x03(\x0b\x32\x1b.windmill.GlobalDataRequest\x12\x31\n\x13glo
bal_data_updates\x18\n \x03(\x0b\x32\x14.windmill.GlobalData\x12\x33\n\x14source_state_updates\x18\x0c \x01(\x0b\x32\x15.windmill.SourceState\x12.\n\x10source_watermark\x18\r \x01(\x03:\x14-9223372036854775808\x12\x30\n\x0fwatermark_holds\x18\x0e \x03(\x0b\x32\x17.windmill.WatermarkHold\x12\x37\n\x17global_data_id_requests\x18\t \x03(\x0b\x32\x16.windmill.GlobalDataId\"i\n\x1c\x43omputationCommitWorkRequest\x12\x16\n\x0e\x63omputation_id\x18\x01 \x02(\t\x12\x31\n\x08requests\x18\x02 \x03(\x0b\x32\x1f.windmill.WorkItemCommitRequest\"]\n\x11\x43ommitWorkRequest\x12\x0e\n\x06job_id\x18\x02 \x01(\t\x12\x38\n\x08requests\x18\x01 \x03(\x0b\x32&.windmill.ComputationCommitWorkRequest\"\x14\n\x12\x43ommitWorkResponse\"8\n\x10GetConfigRequest\x12\x0e\n\x06job_id\x18\x02 \x01(\t\x12\x14\n\x0c\x63omputations\x18\x01 \x03(\t\"\xd8\x02\n\x11GetConfigResponse\x12\x13\n\x0b\x63loud_works\x18\x01 \x03(\t\x12:\n\x08name_map\x18\x02 \x03(\x0b\x32(.windmill.GetConfigResponse.NameMapEntry\x12h\n!system_
name_to_computation_id_map\x18\x03 \x03(\x0b\x32=.windmill.GetConfigResponse.SystemNameToComputationIdMapEntry\x1a\x36\n\x0cNameMapEntry\x12\x11\n\tuser_name\x18\x01 \x01(\t\x12\x13\n\x0bsystem_name\x18\x02 \x01(\t\x1aP\n!SystemNameToComputationIdMapEntry\x12\x13\n\x0bsystem_name\x18\x01 \x01(\t\x12\x16\n\x0e\x63omputation_id\x18\x02 \x01(\t\"E\n\tException\x12\x14\n\x0cstack_frames\x18\x01 \x03(\t\x12\"\n\x05\x63\x61use\x18\x02 \x01(\x0b\x32\x13.windmill.Exception\"\xc8\x01\n\x12ReportStatsRequest\x12\x0e\n\x06job_id\x18\x06 \x01(\t\x12\x16\n\x0e\x63omputation_id\x18\x01 \x01(\t\x12\x0b\n\x03key\x18\x02 \x01(\x0c\x12\x12\n\nwork_token\x18\x03 \x01(\x06\x12\x14\n\x0csharding_key\x18\x07 \x01(\x06\x12\'\n\nexceptions\x18\x04 \x03(\x0b\x32\x13.windmill.Exception\x12*\n\x0f\x63ounter_updates\x18\x05 \x03(\x0b\x32\x11.windmill.Counter\"%\n\x13ReportStatsResponse\x12\x0e\n\x06\x66\x61iled\x18\x01 \x01(\x08\x42\x41\n5com.apache_beam.sdk.runners.worker.windmillB\x08Windmill')
-)
-_sym_db.RegisterFileDescriptor(DESCRIPTOR)
-
-
-
-_TIMER_TYPE = _descriptor.EnumDescriptor(
- name='Type',
- full_name='windmill.Timer.Type',
- filename=None,
- file=DESCRIPTOR,
- values=[
- _descriptor.EnumValueDescriptor(
- name='WATERMARK', index=0, number=0,
- options=None,
- type=None),
- _descriptor.EnumValueDescriptor(
- name='REALTIME', index=1, number=1,
- options=None,
- type=None),
- _descriptor.EnumValueDescriptor(
- name='DEPENDENT_REALTIME', index=2, number=2,
- options=None,
- type=None),
- ],
- containing_type=None,
- options=None,
- serialized_start=245,
- serialized_end=304,
-)
-_sym_db.RegisterEnumDescriptor(_TIMER_TYPE)
-
-_COUNTER_KIND = _descriptor.EnumDescriptor(
- name='Kind',
- full_name='windmill.Counter.Kind',
- filename=None,
- file=DESCRIPTOR,
- values=[
- _descriptor.EnumValueDescriptor(
- name='SUM', index=0, number=0,
- options=None,
- type=None),
- _descriptor.EnumValueDescriptor(
- name='MAX', index=1, number=1,
- options=None,
- type=None),
- _descriptor.EnumValueDescriptor(
- name='MIN', index=2, number=2,
- options=None,
- type=None),
- _descriptor.EnumValueDescriptor(
- name='MEAN', index=3, number=3,
- options=None,
- type=None),
- ],
- containing_type=None,
- options=None,
- serialized_start=3327,
- serialized_end=3370,
-)
-_sym_db.RegisterEnumDescriptor(_COUNTER_KIND)
-
-
-_MESSAGE = _descriptor.Descriptor(
- name='Message',
- full_name='windmill.Message',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='timestamp', full_name='windmill.Message.timestamp', index=0,
- number=1, type=3, cpp_type=2, label=2,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='data', full_name='windmill.Message.data', index=1,
- number=2, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='metadata', full_name='windmill.Message.metadata', index=2,
- number=3, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=28,
- serialized_end=110,
-)
-
-
-_TIMER = _descriptor.Descriptor(
- name='Timer',
- full_name='windmill.Timer',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='tag', full_name='windmill.Timer.tag', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='timestamp', full_name='windmill.Timer.timestamp', index=1,
- number=2, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='type', full_name='windmill.Timer.type', index=2,
- number=3, type=14, cpp_type=8, label=1,
- has_default_value=True, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.Timer.state_family', index=3,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- _TIMER_TYPE,
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=113,
- serialized_end=304,
-)
-
-
-_INPUTMESSAGEBUNDLE = _descriptor.Descriptor(
- name='InputMessageBundle',
- full_name='windmill.InputMessageBundle',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='source_computation_id', full_name='windmill.InputMessageBundle.source_computation_id', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='messages', full_name='windmill.InputMessageBundle.messages', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=306,
- serialized_end=394,
-)
-
-
-_KEYEDMESSAGEBUNDLE = _descriptor.Descriptor(
- name='KeyedMessageBundle',
- full_name='windmill.KeyedMessageBundle',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.KeyedMessageBundle.key', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='sharding_key', full_name='windmill.KeyedMessageBundle.sharding_key', index=1,
- number=4, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='messages', full_name='windmill.KeyedMessageBundle.messages', index=2,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='messages_ids', full_name='windmill.KeyedMessageBundle.messages_ids', index=3,
- number=3, type=12, cpp_type=9, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=396,
- serialized_end=510,
-)
-
-
-_OUTPUTMESSAGEBUNDLE = _descriptor.Descriptor(
- name='OutputMessageBundle',
- full_name='windmill.OutputMessageBundle',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='destination_computation_id', full_name='windmill.OutputMessageBundle.destination_computation_id', index=0,
- number=1, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='destination_stream_id', full_name='windmill.OutputMessageBundle.destination_stream_id', index=1,
- number=3, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='bundles', full_name='windmill.OutputMessageBundle.bundles', index=2,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=513,
- serialized_end=648,
-)
-
-
-_PUBSUBMESSAGEBUNDLE = _descriptor.Descriptor(
- name='PubSubMessageBundle',
- full_name='windmill.PubSubMessageBundle',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='topic', full_name='windmill.PubSubMessageBundle.topic', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='messages', full_name='windmill.PubSubMessageBundle.messages', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='timestamp_label', full_name='windmill.PubSubMessageBundle.timestamp_label', index=2,
- number=3, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='id_label', full_name='windmill.PubSubMessageBundle.id_label', index=3,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=650,
- serialized_end=766,
-)
-
-
-_TIMERBUNDLE = _descriptor.Descriptor(
- name='TimerBundle',
- full_name='windmill.TimerBundle',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='timers', full_name='windmill.TimerBundle.timers', index=0,
- number=1, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=768,
- serialized_end=814,
-)
-
-
-_VALUE = _descriptor.Descriptor(
- name='Value',
- full_name='windmill.Value',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='timestamp', full_name='windmill.Value.timestamp', index=0,
- number=1, type=3, cpp_type=2, label=2,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='data', full_name='windmill.Value.data', index=1,
- number=2, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=816,
- serialized_end=878,
-)
-
-
-_TAGVALUE = _descriptor.Descriptor(
- name='TagValue',
- full_name='windmill.TagValue',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='tag', full_name='windmill.TagValue.tag', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='value', full_name='windmill.TagValue.value', index=1,
- number=2, type=11, cpp_type=10, label=1,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.TagValue.state_family', index=2,
- number=3, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=880,
- serialized_end=957,
-)
-
-
-_TAGLIST = _descriptor.Descriptor(
- name='TagList',
- full_name='windmill.TagList',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='tag', full_name='windmill.TagList.tag', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='end_timestamp', full_name='windmill.TagList.end_timestamp', index=1,
- number=2, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='values', full_name='windmill.TagList.values', index=2,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.TagList.state_family', index=3,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='request_token', full_name='windmill.TagList.request_token', index=4,
- number=7, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='continuation_token', full_name='windmill.TagList.continuation_token', index=5,
- number=5, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='fetch_max_bytes', full_name='windmill.TagList.fetch_max_bytes', index=6,
- number=6, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=9223372036854775807,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=960,
- serialized_end=1179,
-)
-
-
-_GLOBALDATAID = _descriptor.Descriptor(
- name='GlobalDataId',
- full_name='windmill.GlobalDataId',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='tag', full_name='windmill.GlobalDataId.tag', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='version', full_name='windmill.GlobalDataId.version', index=1,
- number=2, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1181,
- serialized_end=1225,
-)
-
-
-_GLOBALDATA = _descriptor.Descriptor(
- name='GlobalData',
- full_name='windmill.GlobalData',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='data_id', full_name='windmill.GlobalData.data_id', index=0,
- number=1, type=11, cpp_type=10, label=2,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='is_ready', full_name='windmill.GlobalData.is_ready', index=1,
- number=2, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='data', full_name='windmill.GlobalData.data', index=2,
- number=3, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.GlobalData.state_family', index=3,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1227,
- serialized_end=1334,
-)
-
-
-_SOURCESTATE = _descriptor.Descriptor(
- name='SourceState',
- full_name='windmill.SourceState',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='state', full_name='windmill.SourceState.state', index=0,
- number=1, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='finalize_ids', full_name='windmill.SourceState.finalize_ids', index=1,
- number=2, type=6, cpp_type=4, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='only_finalize', full_name='windmill.SourceState.only_finalize', index=2,
- number=3, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1336,
- serialized_end=1409,
-)
-
-
-_WATERMARKHOLD = _descriptor.Descriptor(
- name='WatermarkHold',
- full_name='windmill.WatermarkHold',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='tag', full_name='windmill.WatermarkHold.tag', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='timestamps', full_name='windmill.WatermarkHold.timestamps', index=1,
- number=2, type=3, cpp_type=2, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\020\001'))),
- _descriptor.FieldDescriptor(
- name='reset', full_name='windmill.WatermarkHold.reset', index=2,
- number=3, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.WatermarkHold.state_family', index=3,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1411,
- serialized_end=1500,
-)
-
-
-_WORKITEM = _descriptor.Descriptor(
- name='WorkItem',
- full_name='windmill.WorkItem',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.WorkItem.key', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='work_token', full_name='windmill.WorkItem.work_token', index=1,
- number=2, type=6, cpp_type=4, label=2,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='sharding_key', full_name='windmill.WorkItem.sharding_key', index=2,
- number=9, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='cache_token', full_name='windmill.WorkItem.cache_token', index=3,
- number=7, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='message_bundles', full_name='windmill.WorkItem.message_bundles', index=4,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='timers', full_name='windmill.WorkItem.timers', index=5,
- number=4, type=11, cpp_type=10, label=1,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_id_notifications', full_name='windmill.WorkItem.global_data_id_notifications', index=6,
- number=5, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='source_state', full_name='windmill.WorkItem.source_state', index=7,
- number=6, type=11, cpp_type=10, label=1,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='output_data_watermark', full_name='windmill.WorkItem.output_data_watermark', index=8,
- number=8, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1503,
- serialized_end=1843,
-)
-
-
-_COMPUTATIONWORKITEMS = _descriptor.Descriptor(
- name='ComputationWorkItems',
- full_name='windmill.ComputationWorkItems',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.ComputationWorkItems.computation_id', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='work', full_name='windmill.ComputationWorkItems.work', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='input_data_watermark', full_name='windmill.ComputationWorkItems.input_data_watermark', index=2,
- number=3, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='dependent_realtime_input_watermark', full_name='windmill.ComputationWorkItems.dependent_realtime_input_watermark', index=3,
- number=4, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=1846,
- serialized_end=2044,
-)
-
-
-_GETWORKREQUEST = _descriptor.Descriptor(
- name='GetWorkRequest',
- full_name='windmill.GetWorkRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='client_id', full_name='windmill.GetWorkRequest.client_id', index=0,
- number=1, type=6, cpp_type=4, label=2,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='worker_id', full_name='windmill.GetWorkRequest.worker_id', index=1,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='job_id', full_name='windmill.GetWorkRequest.job_id', index=2,
- number=5, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='max_items', full_name='windmill.GetWorkRequest.max_items', index=3,
- number=2, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=4294967295,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='max_bytes', full_name='windmill.GetWorkRequest.max_bytes', index=4,
- number=3, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=9223372036854775807,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2047,
- serialized_end=2188,
-)
-
-
-_GETWORKRESPONSE = _descriptor.Descriptor(
- name='GetWorkResponse',
- full_name='windmill.GetWorkResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='work', full_name='windmill.GetWorkResponse.work', index=0,
- number=1, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2190,
- serialized_end=2253,
-)
-
-
-_KEYEDGETDATAREQUEST = _descriptor.Descriptor(
- name='KeyedGetDataRequest',
- full_name='windmill.KeyedGetDataRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.KeyedGetDataRequest.key', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='work_token', full_name='windmill.KeyedGetDataRequest.work_token', index=1,
- number=2, type=6, cpp_type=4, label=2,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='sharding_key', full_name='windmill.KeyedGetDataRequest.sharding_key', index=2,
- number=6, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='values_to_fetch', full_name='windmill.KeyedGetDataRequest.values_to_fetch', index=3,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='lists_to_fetch', full_name='windmill.KeyedGetDataRequest.lists_to_fetch', index=4,
- number=4, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='watermark_holds_to_fetch', full_name='windmill.KeyedGetDataRequest.watermark_holds_to_fetch', index=5,
- number=5, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2256,
- serialized_end=2479,
-)
-
-
-_COMPUTATIONGETDATAREQUEST = _descriptor.Descriptor(
- name='ComputationGetDataRequest',
- full_name='windmill.ComputationGetDataRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.ComputationGetDataRequest.computation_id', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='requests', full_name='windmill.ComputationGetDataRequest.requests', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2481,
- serialized_end=2581,
-)
-
-
-_GETDATAREQUEST = _descriptor.Descriptor(
- name='GetDataRequest',
- full_name='windmill.GetDataRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='job_id', full_name='windmill.GetDataRequest.job_id', index=0,
- number=4, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='requests', full_name='windmill.GetDataRequest.requests', index=1,
- number=1, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_fetch_requests', full_name='windmill.GetDataRequest.global_data_fetch_requests', index=2,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_to_fetch', full_name='windmill.GetDataRequest.global_data_to_fetch', index=3,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2584,
- serialized_end=2790,
-)
-
-
-_KEYEDGETDATARESPONSE = _descriptor.Descriptor(
- name='KeyedGetDataResponse',
- full_name='windmill.KeyedGetDataResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.KeyedGetDataResponse.key', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='failed', full_name='windmill.KeyedGetDataResponse.failed', index=1,
- number=2, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='values', full_name='windmill.KeyedGetDataResponse.values', index=2,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='lists', full_name='windmill.KeyedGetDataResponse.lists', index=3,
- number=4, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='watermark_holds', full_name='windmill.KeyedGetDataResponse.watermark_holds', index=4,
- number=5, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2793,
- serialized_end=2964,
-)
-
-
-_COMPUTATIONGETDATARESPONSE = _descriptor.Descriptor(
- name='ComputationGetDataResponse',
- full_name='windmill.ComputationGetDataResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.ComputationGetDataResponse.computation_id', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='data', full_name='windmill.ComputationGetDataResponse.data', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=2966,
- serialized_end=3064,
-)
-
-
-_GETDATARESPONSE = _descriptor.Descriptor(
- name='GetDataResponse',
- full_name='windmill.GetDataResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='data', full_name='windmill.GetDataResponse.data', index=0,
- number=1, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data', full_name='windmill.GetDataResponse.global_data', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=3066,
- serialized_end=3178,
-)
-
-
-_COUNTER = _descriptor.Descriptor(
- name='Counter',
- full_name='windmill.Counter',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='name', full_name='windmill.Counter.name', index=0,
- number=1, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='kind', full_name='windmill.Counter.kind', index=1,
- number=2, type=14, cpp_type=8, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='double_scalar', full_name='windmill.Counter.double_scalar', index=2,
- number=3, type=1, cpp_type=5, label=1,
- has_default_value=False, default_value=float(0),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='int_scalar', full_name='windmill.Counter.int_scalar', index=3,
- number=4, type=3, cpp_type=2, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='mean_count', full_name='windmill.Counter.mean_count', index=4,
- number=6, type=3, cpp_type=2, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='cumulative', full_name='windmill.Counter.cumulative', index=5,
- number=7, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- _COUNTER_KIND,
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=3181,
- serialized_end=3370,
-)
-
-
-_GLOBALDATAREQUEST = _descriptor.Descriptor(
- name='GlobalDataRequest',
- full_name='windmill.GlobalDataRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='data_id', full_name='windmill.GlobalDataRequest.data_id', index=0,
- number=1, type=11, cpp_type=10, label=2,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='existence_watermark_deadline', full_name='windmill.GlobalDataRequest.existence_watermark_deadline', index=1,
- number=2, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=9223372036854775807,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='state_family', full_name='windmill.GlobalDataRequest.state_family', index=2,
- number=3, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=3373,
- serialized_end=3514,
-)
-
-
-_WORKITEMCOMMITREQUEST = _descriptor.Descriptor(
- name='WorkItemCommitRequest',
- full_name='windmill.WorkItemCommitRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.WorkItemCommitRequest.key', index=0,
- number=1, type=12, cpp_type=9, label=2,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='work_token', full_name='windmill.WorkItemCommitRequest.work_token', index=1,
- number=2, type=6, cpp_type=4, label=2,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='sharding_key', full_name='windmill.WorkItemCommitRequest.sharding_key', index=2,
- number=15, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='output_messages', full_name='windmill.WorkItemCommitRequest.output_messages', index=3,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='pubsub_messages', full_name='windmill.WorkItemCommitRequest.pubsub_messages', index=4,
- number=7, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='output_timers', full_name='windmill.WorkItemCommitRequest.output_timers', index=5,
- number=4, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='value_updates', full_name='windmill.WorkItemCommitRequest.value_updates', index=6,
- number=5, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='list_updates', full_name='windmill.WorkItemCommitRequest.list_updates', index=7,
- number=6, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='counter_updates', full_name='windmill.WorkItemCommitRequest.counter_updates', index=8,
- number=8, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_requests', full_name='windmill.WorkItemCommitRequest.global_data_requests', index=9,
- number=11, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_updates', full_name='windmill.WorkItemCommitRequest.global_data_updates', index=10,
- number=10, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='source_state_updates', full_name='windmill.WorkItemCommitRequest.source_state_updates', index=11,
- number=12, type=11, cpp_type=10, label=1,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='source_watermark', full_name='windmill.WorkItemCommitRequest.source_watermark', index=12,
- number=13, type=3, cpp_type=2, label=1,
- has_default_value=True, default_value=-9223372036854775808,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='watermark_holds', full_name='windmill.WorkItemCommitRequest.watermark_holds', index=13,
- number=14, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='global_data_id_requests', full_name='windmill.WorkItemCommitRequest.global_data_id_requests', index=14,
- number=9, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=3517,
- serialized_end=4193,
-)
-
-
-_COMPUTATIONCOMMITWORKREQUEST = _descriptor.Descriptor(
- name='ComputationCommitWorkRequest',
- full_name='windmill.ComputationCommitWorkRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.ComputationCommitWorkRequest.computation_id', index=0,
- number=1, type=9, cpp_type=9, label=2,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='requests', full_name='windmill.ComputationCommitWorkRequest.requests', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4195,
- serialized_end=4300,
-)
-
-
-_COMMITWORKREQUEST = _descriptor.Descriptor(
- name='CommitWorkRequest',
- full_name='windmill.CommitWorkRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='job_id', full_name='windmill.CommitWorkRequest.job_id', index=0,
- number=2, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='requests', full_name='windmill.CommitWorkRequest.requests', index=1,
- number=1, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4302,
- serialized_end=4395,
-)
-
-
-_COMMITWORKRESPONSE = _descriptor.Descriptor(
- name='CommitWorkResponse',
- full_name='windmill.CommitWorkResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4397,
- serialized_end=4417,
-)
-
-
-_GETCONFIGREQUEST = _descriptor.Descriptor(
- name='GetConfigRequest',
- full_name='windmill.GetConfigRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='job_id', full_name='windmill.GetConfigRequest.job_id', index=0,
- number=2, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='computations', full_name='windmill.GetConfigRequest.computations', index=1,
- number=1, type=9, cpp_type=9, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4419,
- serialized_end=4475,
-)
-
-
-_GETCONFIGRESPONSE_NAMEMAPENTRY = _descriptor.Descriptor(
- name='NameMapEntry',
- full_name='windmill.GetConfigResponse.NameMapEntry',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='user_name', full_name='windmill.GetConfigResponse.NameMapEntry.user_name', index=0,
- number=1, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='system_name', full_name='windmill.GetConfigResponse.NameMapEntry.system_name', index=1,
- number=2, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4686,
- serialized_end=4740,
-)
-
-_GETCONFIGRESPONSE_SYSTEMNAMETOCOMPUTATIONIDMAPENTRY = _descriptor.Descriptor(
- name='SystemNameToComputationIdMapEntry',
- full_name='windmill.GetConfigResponse.SystemNameToComputationIdMapEntry',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='system_name', full_name='windmill.GetConfigResponse.SystemNameToComputationIdMapEntry.system_name', index=0,
- number=1, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.GetConfigResponse.SystemNameToComputationIdMapEntry.computation_id', index=1,
- number=2, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4742,
- serialized_end=4822,
-)
-
-_GETCONFIGRESPONSE = _descriptor.Descriptor(
- name='GetConfigResponse',
- full_name='windmill.GetConfigResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='cloud_works', full_name='windmill.GetConfigResponse.cloud_works', index=0,
- number=1, type=9, cpp_type=9, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='name_map', full_name='windmill.GetConfigResponse.name_map', index=1,
- number=2, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='system_name_to_computation_id_map', full_name='windmill.GetConfigResponse.system_name_to_computation_id_map', index=2,
- number=3, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[_GETCONFIGRESPONSE_NAMEMAPENTRY, _GETCONFIGRESPONSE_SYSTEMNAMETOCOMPUTATIONIDMAPENTRY, ],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4478,
- serialized_end=4822,
-)
-
-
-_EXCEPTION = _descriptor.Descriptor(
- name='Exception',
- full_name='windmill.Exception',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='stack_frames', full_name='windmill.Exception.stack_frames', index=0,
- number=1, type=9, cpp_type=9, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='cause', full_name='windmill.Exception.cause', index=1,
- number=2, type=11, cpp_type=10, label=1,
- has_default_value=False, default_value=None,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4824,
- serialized_end=4893,
-)
-
-
-_REPORTSTATSREQUEST = _descriptor.Descriptor(
- name='ReportStatsRequest',
- full_name='windmill.ReportStatsRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='job_id', full_name='windmill.ReportStatsRequest.job_id', index=0,
- number=6, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='computation_id', full_name='windmill.ReportStatsRequest.computation_id', index=1,
- number=1, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='key', full_name='windmill.ReportStatsRequest.key', index=2,
- number=2, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='work_token', full_name='windmill.ReportStatsRequest.work_token', index=3,
- number=3, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='sharding_key', full_name='windmill.ReportStatsRequest.sharding_key', index=4,
- number=7, type=6, cpp_type=4, label=1,
- has_default_value=False, default_value=0,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='exceptions', full_name='windmill.ReportStatsRequest.exceptions', index=5,
- number=4, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- _descriptor.FieldDescriptor(
- name='counter_updates', full_name='windmill.ReportStatsRequest.counter_updates', index=6,
- number=5, type=11, cpp_type=10, label=3,
- has_default_value=False, default_value=[],
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=4896,
- serialized_end=5096,
-)
-
-
-_REPORTSTATSRESPONSE = _descriptor.Descriptor(
- name='ReportStatsResponse',
- full_name='windmill.ReportStatsResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='failed', full_name='windmill.ReportStatsResponse.failed', index=0,
- number=1, type=8, cpp_type=7, label=1,
- has_default_value=False, default_value=False,
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto2',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=5098,
- serialized_end=5135,
-)
-
-_TIMER.fields_by_name['type'].enum_type = _TIMER_TYPE
-_TIMER_TYPE.containing_type = _TIMER
-_INPUTMESSAGEBUNDLE.fields_by_name['messages'].message_type = _MESSAGE
-_KEYEDMESSAGEBUNDLE.fields_by_name['messages'].message_type = _MESSAGE
-_OUTPUTMESSAGEBUNDLE.fields_by_name['bundles'].message_type = _KEYEDMESSAGEBUNDLE
-_PUBSUBMESSAGEBUNDLE.fields_by_name['messages'].message_type = _MESSAGE
-_TIMERBUNDLE.fields_by_name['timers'].message_type = _TIMER
-_TAGVALUE.fields_by_name['value'].message_type = _VALUE
-_TAGLIST.fields_by_name['values'].message_type = _VALUE
-_GLOBALDATA.fields_by_name['data_id'].message_type = _GLOBALDATAID
-_WORKITEM.fields_by_name['message_bundles'].message_type = _INPUTMESSAGEBUNDLE
-_WORKITEM.fields_by_name['timers'].message_type = _TIMERBUNDLE
-_WORKITEM.fields_by_name['global_data_id_notifications'].message_type = _GLOBALDATAID
-_WORKITEM.fields_by_name['source_state'].message_type = _SOURCESTATE
-_COMPUTATIONWORKITEMS.fields_by_name['work'].message_type = _WORKITEM
-_GETWORKRESPONSE.fields_by_name['work'].message_type = _COMPUTATIONWORKITEMS
-_KEYEDGETDATAREQUEST.fields_by_name['values_to_fetch'].message_type = _TAGVALUE
-_KEYEDGETDATAREQUEST.fields_by_name['lists_to_fetch'].message_type = _TAGLIST
-_KEYEDGETDATAREQUEST.fields_by_name['watermark_holds_to_fetch'].message_type = _WATERMARKHOLD
-_COMPUTATIONGETDATAREQUEST.fields_by_name['requests'].message_type = _KEYEDGETDATAREQUEST
-_GETDATAREQUEST.fields_by_name['requests'].message_type = _COMPUTATIONGETDATAREQUEST
-_GETDATAREQUEST.fields_by_name['global_data_fetch_requests'].message_type = _GLOBALDATAREQUEST
-_GETDATAREQUEST.fields_by_name['global_data_to_fetch'].message_type = _GLOBALDATAID
-_KEYEDGETDATARESPONSE.fields_by_name['values'].message_type = _TAGVALUE
-_KEYEDGETDATARESPONSE.fields_by_name['lists'].message_type = _TAGLIST
-_KEYEDGETDATARESPONSE.fields_by_name['watermark_holds'].message_type = _WATERMARKHOLD
-_COMPUTATIONGETDATARESPONSE.fields_by_name['data'].message_type = _KEYEDGETDATARESPONSE
-_GETDATARESPONSE.fields_by_name['data'].message_type = _COMPUTATIONGETDATARESPONSE
-_GETDATARESPONSE.fields_by_name['global_data'].message_type = _GLOBALDATA
-_COUNTER.fields_by_name['kind'].enum_type = _COUNTER_KIND
-_COUNTER_KIND.containing_type = _COUNTER
-_GLOBALDATAREQUEST.fields_by_name['data_id'].message_type = _GLOBALDATAID
-_WORKITEMCOMMITREQUEST.fields_by_name['output_messages'].message_type = _OUTPUTMESSAGEBUNDLE
-_WORKITEMCOMMITREQUEST.fields_by_name['pubsub_messages'].message_type = _PUBSUBMESSAGEBUNDLE
-_WORKITEMCOMMITREQUEST.fields_by_name['output_timers'].message_type = _TIMER
-_WORKITEMCOMMITREQUEST.fields_by_name['value_updates'].message_type = _TAGVALUE
-_WORKITEMCOMMITREQUEST.fields_by_name['list_updates'].message_type = _TAGLIST
-_WORKITEMCOMMITREQUEST.fields_by_name['counter_updates'].message_type = _COUNTER
-_WORKITEMCOMMITREQUEST.fields_by_name['global_data_requests'].message_type = _GLOBALDATAREQUEST
-_WORKITEMCOMMITREQUEST.fields_by_name['global_data_updates'].message_type = _GLOBALDATA
-_WORKITEMCOMMITREQUEST.fields_by_name['source_state_updates'].message_type = _SOURCESTATE
-_WORKITEMCOMMITREQUEST.fields_by_name['watermark_holds'].message_type = _WATERMARKHOLD
-_WORKITEMCOMMITREQUEST.fields_by_name['global_data_id_requests'].message_type = _GLOBALDATAID
-_COMPUTATIONCOMMITWORKREQUEST.fields_by_name['requests'].message_type = _WORKITEMCOMMITREQUEST
-_COMMITWORKREQUEST.fields_by_name['requests'].message_type = _COMPUTATIONCOMMITWORKREQUEST
-_GETCONFIGRESPONSE_NAMEMAPENTRY.containing_type = _GETCONFIGRESPONSE
-_GETCONFIGRESPONSE_SYSTEMNAMETOCOMPUTATIONIDMAPENTRY.containing_type = _GETCONFIGRESPONSE
-_GETCONFIGRESPONSE.fields_by_name['name_map'].message_type = _GETCONFIGRESPONSE_NAMEMAPENTRY
-_GETCONFIGRESPONSE.fields_by_name['system_name_to_computation_id_map'].message_type = _GETCONFIGRESPONSE_SYSTEMNAMETOCOMPUTATIONIDMAPENTRY
-_EXCEPTION.fields_by_name['cause'].message_type = _EXCEPTION
-_REPORTSTATSREQUEST.fields_by_name['exceptions'].message_type = _EXCEPTION
-_REPORTSTATSREQUEST.fields_by_name['counter_updates'].message_type = _COUNTER
-DESCRIPTOR.message_types_by_name['Message'] = _MESSAGE
-DESCRIPTOR.message_types_by_name['Timer'] = _TIMER
-DESCRIPTOR.message_types_by_name['InputMessageBundle'] = _INPUTMESSAGEBUNDLE
-DESCRIPTOR.message_types_by_name['KeyedMessageBundle'] = _KEYEDMESSAGEBUNDLE
-DESCRIPTOR.message_types_by_name['OutputMessageBundle'] = _OUTPUTMESSAGEBUNDLE
-DESCRIPTOR.message_types_by_name['PubSubMessageBundle'] = _PUBSUBMESSAGEBUNDLE
-DESCRIPTOR.message_types_by_name['TimerBundle'] = _TIMERBUNDLE
-DESCRIPTOR.message_types_by_name['Value'] = _VALUE
-DESCRIPTOR.message_types_by_name['TagValue'] = _TAGVALUE
-DESCRIPTOR.message_types_by_name['TagList'] = _TAGLIST
-DESCRIPTOR.message_types_by_name['GlobalDataId'] = _GLOBALDATAID
-DESCRIPTOR.message_types_by_name['GlobalData'] = _GLOBALDATA
-DESCRIPTOR.message_types_by_name['SourceState'] = _SOURCESTATE
-DESCRIPTOR.message_types_by_name['WatermarkHold'] = _WATERMARKHOLD
-DESCRIPTOR.message_types_by_name['WorkItem'] = _WORKITEM
-DESCRIPTOR.message_types_by_name['ComputationWorkItems'] = _COMPUTATIONWORKITEMS
-DESCRIPTOR.message_types_by_name['GetWorkRequest'] = _GETWORKREQUEST
-DESCRIPTOR.message_types_by_name['GetWorkResponse'] = _GETWORKRESPONSE
-DESCRIPTOR.message_types_by_name['KeyedGetDataRequest'] = _KEYEDGETDATAREQUEST
-DESCRIPTOR.message_types_by_name['ComputationGetDataRequest'] = _COMPUTATIONGETDATAREQUEST
-DESCRIPTOR.message_types_by_name['GetDataRequest'] = _GETDATAREQUEST
-DESCRIPTOR.message_types_by_name['KeyedGetDataResponse'] = _KEYEDGETDATARESPONSE
-DESCRIPTOR.message_types_by_name['ComputationGetDataResponse'] = _COMPUTATIONGETDATARESPONSE
-DESCRIPTOR.message_types_by_name['GetDataResponse'] = _GETDATARESPONSE
-DESCRIPTOR.message_types_by_name['Counter'] = _COUNTER
-DESCRIPTOR.message_types_by_name['GlobalDataRequest'] = _GLOBALDATAREQUEST
-DESCRIPTOR.message_types_by_name['WorkItemCommitRequest'] = _WORKITEMCOMMITREQUEST
-DESCRIPTOR.message_types_by_name['ComputationCommitWorkRequest'] = _COMPUTATIONCOMMITWORKREQUEST
-DESCRIPTOR.message_types_by_name['CommitWorkRequest'] = _COMMITWORKREQUEST
-DESCRIPTOR.message_types_by_name['CommitWorkResponse'] = _COMMITWORKRESPONSE
-DESCRIPTOR.message_types_by_name['GetConfigRequest'] = _GETCONFIGREQUEST
-DESCRIPTOR.message_types_by_name['GetConfigResponse'] = _GETCONFIGRESPONSE
-DESCRIPTOR.message_types_by_name['Exception'] = _EXCEPTION
-DESCRIPTOR.message_types_by_name['ReportStatsRequest'] = _REPORTSTATSREQUEST
-DESCRIPTOR.message_types_by_name['ReportStatsResponse'] = _REPORTSTATSRESPONSE
-
-Message = _reflection.GeneratedProtocolMessageType('Message', (_message.Message,), dict(
- DESCRIPTOR = _MESSAGE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.Message)
- ))
-_sym_db.RegisterMessage(Message)
-
-Timer = _reflection.GeneratedProtocolMessageType('Timer', (_message.Message,), dict(
- DESCRIPTOR = _TIMER,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.Timer)
- ))
-_sym_db.RegisterMessage(Timer)
-
-InputMessageBundle = _reflection.GeneratedProtocolMessageType('InputMessageBundle', (_message.Message,), dict(
- DESCRIPTOR = _INPUTMESSAGEBUNDLE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.InputMessageBundle)
- ))
-_sym_db.RegisterMessage(InputMessageBundle)
-
-KeyedMessageBundle = _reflection.GeneratedProtocolMessageType('KeyedMessageBundle', (_message.Message,), dict(
- DESCRIPTOR = _KEYEDMESSAGEBUNDLE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.KeyedMessageBundle)
- ))
-_sym_db.RegisterMessage(KeyedMessageBundle)
-
-OutputMessageBundle = _reflection.GeneratedProtocolMessageType('OutputMessageBundle', (_message.Message,), dict(
- DESCRIPTOR = _OUTPUTMESSAGEBUNDLE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.OutputMessageBundle)
- ))
-_sym_db.RegisterMessage(OutputMessageBundle)
-
-PubSubMessageBundle = _reflection.GeneratedProtocolMessageType('PubSubMessageBundle', (_message.Message,), dict(
- DESCRIPTOR = _PUBSUBMESSAGEBUNDLE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.PubSubMessageBundle)
- ))
-_sym_db.RegisterMessage(PubSubMessageBundle)
-
-TimerBundle = _reflection.GeneratedProtocolMessageType('TimerBundle', (_message.Message,), dict(
- DESCRIPTOR = _TIMERBUNDLE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.TimerBundle)
- ))
-_sym_db.RegisterMessage(TimerBundle)
-
-Value = _reflection.GeneratedProtocolMessageType('Value', (_message.Message,), dict(
- DESCRIPTOR = _VALUE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.Value)
- ))
-_sym_db.RegisterMessage(Value)
-
-TagValue = _reflection.GeneratedProtocolMessageType('TagValue', (_message.Message,), dict(
- DESCRIPTOR = _TAGVALUE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.TagValue)
- ))
-_sym_db.RegisterMessage(TagValue)
-
-TagList = _reflection.GeneratedProtocolMessageType('TagList', (_message.Message,), dict(
- DESCRIPTOR = _TAGLIST,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.TagList)
- ))
-_sym_db.RegisterMessage(TagList)
-
-GlobalDataId = _reflection.GeneratedProtocolMessageType('GlobalDataId', (_message.Message,), dict(
- DESCRIPTOR = _GLOBALDATAID,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GlobalDataId)
- ))
-_sym_db.RegisterMessage(GlobalDataId)
-
-GlobalData = _reflection.GeneratedProtocolMessageType('GlobalData', (_message.Message,), dict(
- DESCRIPTOR = _GLOBALDATA,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GlobalData)
- ))
-_sym_db.RegisterMessage(GlobalData)
-
-SourceState = _reflection.GeneratedProtocolMessageType('SourceState', (_message.Message,), dict(
- DESCRIPTOR = _SOURCESTATE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.SourceState)
- ))
-_sym_db.RegisterMessage(SourceState)
-
-WatermarkHold = _reflection.GeneratedProtocolMessageType('WatermarkHold', (_message.Message,), dict(
- DESCRIPTOR = _WATERMARKHOLD,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.WatermarkHold)
- ))
-_sym_db.RegisterMessage(WatermarkHold)
-
-WorkItem = _reflection.GeneratedProtocolMessageType('WorkItem', (_message.Message,), dict(
- DESCRIPTOR = _WORKITEM,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.WorkItem)
- ))
-_sym_db.RegisterMessage(WorkItem)
-
-ComputationWorkItems = _reflection.GeneratedProtocolMessageType('ComputationWorkItems', (_message.Message,), dict(
- DESCRIPTOR = _COMPUTATIONWORKITEMS,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.ComputationWorkItems)
- ))
-_sym_db.RegisterMessage(ComputationWorkItems)
-
-GetWorkRequest = _reflection.GeneratedProtocolMessageType('GetWorkRequest', (_message.Message,), dict(
- DESCRIPTOR = _GETWORKREQUEST,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GetWorkRequest)
- ))
-_sym_db.RegisterMessage(GetWorkRequest)
-
-GetWorkResponse = _reflection.GeneratedProtocolMessageType('GetWorkResponse', (_message.Message,), dict(
- DESCRIPTOR = _GETWORKRESPONSE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GetWorkResponse)
- ))
-_sym_db.RegisterMessage(GetWorkResponse)
-
-KeyedGetDataRequest = _reflection.GeneratedProtocolMessageType('KeyedGetDataRequest', (_message.Message,), dict(
- DESCRIPTOR = _KEYEDGETDATAREQUEST,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.KeyedGetDataRequest)
- ))
-_sym_db.RegisterMessage(KeyedGetDataRequest)
-
-ComputationGetDataRequest = _reflection.GeneratedProtocolMessageType('ComputationGetDataRequest', (_message.Message,), dict(
- DESCRIPTOR = _COMPUTATIONGETDATAREQUEST,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.ComputationGetDataRequest)
- ))
-_sym_db.RegisterMessage(ComputationGetDataRequest)
-
-GetDataRequest = _reflection.GeneratedProtocolMessageType('GetDataRequest', (_message.Message,), dict(
- DESCRIPTOR = _GETDATAREQUEST,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GetDataRequest)
- ))
-_sym_db.RegisterMessage(GetDataRequest)
-
-KeyedGetDataResponse = _reflection.GeneratedProtocolMessageType('KeyedGetDataResponse', (_message.Message,), dict(
- DESCRIPTOR = _KEYEDGETDATARESPONSE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.KeyedGetDataResponse)
- ))
-_sym_db.RegisterMessage(KeyedGetDataResponse)
-
-ComputationGetDataResponse = _reflection.GeneratedProtocolMessageType('ComputationGetDataResponse', (_message.Message,), dict(
- DESCRIPTOR = _COMPUTATIONGETDATARESPONSE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.ComputationGetDataResponse)
- ))
-_sym_db.RegisterMessage(ComputationGetDataResponse)
-
-GetDataResponse = _reflection.GeneratedProtocolMessageType('GetDataResponse', (_message.Message,), dict(
- DESCRIPTOR = _GETDATARESPONSE,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.GetDataResponse)
- ))
-_sym_db.RegisterMessage(GetDataResponse)
-
-Counter = _reflection.GeneratedProtocolMessageType('Counter', (_message.Message,), dict(
- DESCRIPTOR = _COUNTER,
- __module__ = 'windmill_pb2'
- # @@protoc_insertion_point(class_scope:windmill.Counter)
- ))
-_sym_db.RegisterMessage(Counter)
-
-GlobalData
<TRUNCATED>
[4/4] beam git commit: This closes #2001
Posted by al...@apache.org.
This closes #2001
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2685ba52
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2685ba52
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2685ba52
Branch: refs/heads/master
Commit: 2685ba528d1c9c0dd1d4900dc8e84c9f78c0e5d8
Parents: 0d3389a 88b2d9b
Author: Ahmet Altay <al...@google.com>
Authored: Tue Feb 14 16:16:12 2017 -0800
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Feb 14 16:16:12 2017 -0800
----------------------------------------------------------------------
sdks/python/.pylintrc | 2 +-
.../python/apache_beam/internal/windmill_pb2.py | 2278 ------------------
.../internal/windmill_service_pb2.py | 164 --
sdks/python/run_pylint.sh | 2 -
4 files changed, 1 insertion(+), 2445 deletions(-)
----------------------------------------------------------------------
[3/4] beam git commit: [BEAM-1473] Remove unused windmill proto from
python sdk
Posted by al...@apache.org.
[BEAM-1473] Remove unused windmill proto from python sdk
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/88b2d9b2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/88b2d9b2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/88b2d9b2
Branch: refs/heads/master
Commit: 88b2d9b20034f6f561195707b2316ddb4dfd43de
Parents: 0d3389a
Author: Sourabh Bajaj <so...@google.com>
Authored: Tue Feb 14 16:13:48 2017 -0800
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Feb 14 16:16:01 2017 -0800
----------------------------------------------------------------------
sdks/python/.pylintrc | 2 +-
.../python/apache_beam/internal/windmill_pb2.py | 2278 ------------------
.../internal/windmill_service_pb2.py | 164 --
sdks/python/run_pylint.sh | 2 -
4 files changed, 1 insertion(+), 2445 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/88b2d9b2/sdks/python/.pylintrc
----------------------------------------------------------------------
diff --git a/sdks/python/.pylintrc b/sdks/python/.pylintrc
index c69fd2b..7a0611a 100644
--- a/sdks/python/.pylintrc
+++ b/sdks/python/.pylintrc
@@ -17,7 +17,7 @@
[MASTER]
# Ignore auto-generated files.
-ignore=clients,windmill_pb2.py,windmill_service_pb2.py
+ignore=clients
[BASIC]
# Regular expression which should only match the name