From 6e58beadbdf295d18d2aa4e6a7698f2d9f27ea96 Mon Sep 17 00:00:00 2001 From: Satwant Rana Date: Tue, 27 Aug 2024 02:41:21 +0530 Subject: [PATCH] Update proto generated files and fix test. --- fennel/datasets/test_dataset.py | 330 +++++++++++++++++------------- fennel/gen/auth_pb2.py | 1 + fennel/gen/connector_pb2.py | 1 + fennel/gen/dataset_pb2.py | 117 +++++------ fennel/gen/dataset_pb2.pyi | 5 +- fennel/gen/expectations_pb2.py | 1 + fennel/gen/expr_pb2.py | 1 + fennel/gen/featureset_pb2.py | 19 +- fennel/gen/featureset_pb2.pyi | 8 +- fennel/gen/format_pb2.py | 1 + fennel/gen/http_auth_pb2.py | 1 + fennel/gen/index_pb2.py | 1 + fennel/gen/kinesis_pb2.py | 1 + fennel/gen/metadata_pb2.py | 1 + fennel/gen/pycode_pb2.py | 1 + fennel/gen/pycode_pb2.pyi | 2 +- fennel/gen/schema_pb2.py | 1 + fennel/gen/schema_registry_pb2.py | 1 + fennel/gen/services_pb2.py | 1 + fennel/gen/spec_pb2.py | 1 + fennel/gen/status_pb2.py | 1 + fennel/gen/window_pb2.py | 1 + 22 files changed, 282 insertions(+), 215 deletions(-) diff --git a/fennel/datasets/test_dataset.py b/fennel/datasets/test_dataset.py index e25c250cd..a4d66cdde 100644 --- a/fennel/datasets/test_dataset.py +++ b/fennel/datasets/test_dataset.py @@ -693,18 +693,19 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABCDataset", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "how": 0, - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABCDataset", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + } + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -865,18 +866,19 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABCDatasetDefault", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "how": 0, - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABCDatasetDefault", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + } + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -963,18 +965,19 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABCDatasetDefault", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "how": 0, - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABCDatasetDefault", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + } + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1061,19 +1064,20 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABDatasetLow", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "within_low": "3600s", - "how": 0, - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABDatasetLow", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + }, + "withinLow":"3600s" + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1160,19 +1164,20 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABDatasetHigh", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "how": 0, - "within_high": "86400s", - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABDatasetHigh", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + }, + "withinHigh":"86400s" + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1259,20 +1264,21 @@ def pipeline1(cls, a: Dataset, b: Dataset): ) operator_req = sync_request.operators[2] o = { - "id": "12a2088d8d7a0d265a7bd3f694fc81aa", - "is_root": True, - "pipeline_name": "pipeline1", - "dataset_name": "ABDataset", - "join": { - "lhs_operand_id": "A", - "rhs_dsref_operand_id": "B", - "on": {"a1": "b1"}, - "how": 0, - "within_low": "259200s", - "within_high": "31536000s", - }, - "ds_version": 1, - } + "id":"3338ee30aac1dc899789da9fc78fa025", + "isRoot":True, + "pipelineName":"pipeline1", + "datasetName":"ABDataset", + "join":{ + "lhsOperandId":"A", + "rhsDsrefOperandId":"B", + "on":{ + "a1":"b1" + }, + "withinLow":"259200s", + "withinHigh":"31536000s" + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1476,17 +1482,18 @@ def extract_info(df: pd.DataFrame) -> pd.DataFrame: operator_req = sync_request.operators[3] o = { - "id": "4202e94cf2e47bf5bcc94fd57aee8d0f", - "pipelineName": "create_fraud_dataset", - "datasetName": "FraudReportAggregatedDataset", - "join": { - "lhsOperandId": "101097826c6986ddb25ce924985d9217", - "rhsDsrefOperandId": "UserInfoDataset", - "on": {"user_id": "user_id"}, - "how": 0, - }, - "ds_version": 1, - } + "id":"246863a3fc1191098d24b4034f704851", + "pipelineName":"create_fraud_dataset", + "datasetName":"FraudReportAggregatedDataset", + "join":{ + "lhsOperandId":"101097826c6986ddb25ce924985d9217", + "rhsDsrefOperandId":"UserInfoDataset", + "on":{ + "user_id":"user_id" + } + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1494,20 +1501,38 @@ def extract_info(df: pd.DataFrame) -> pd.DataFrame: operator_req = erase_operator_pycode(sync_request.operators[4]) o = { - "id": "bfa10d216f843625785d24e6b9d890fb", - "pipelineName": "create_fraud_dataset", - "datasetName": "FraudReportAggregatedDataset", - "transform": { - "operandId": "4202e94cf2e47bf5bcc94fd57aee8d0f", - "schema": { - "user_id": {"intType": {}}, - "merchant_id": {"intType": {}}, - "timestamp": {"timestampType": {}}, - "transaction_amount": {"doubleType": {}}, - }, - "pycode": {}, - }, - } + "id":"6158406804b946bda0c38a994229e995", + "pipelineName":"create_fraud_dataset", + "datasetName":"FraudReportAggregatedDataset", + "transform":{ + "operandId":"246863a3fc1191098d24b4034f704851", + "schema":{ + "user_id":{ + "intType":{ + + } + }, + "merchant_id":{ + "intType":{ + + } + }, + "timestamp":{ + "timestampType":{ + + } + }, + "transaction_amount":{ + "doubleType":{ + + } + } + }, + "pycode":{ + + } + } + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1515,15 +1540,18 @@ def extract_info(df: pd.DataFrame) -> pd.DataFrame: operator_req = sync_request.operators[5] o = { - "id": "acd519ba5789e767383099d0561e07c8", - "pipelineName": "create_fraud_dataset", - "datasetName": "FraudReportAggregatedDataset", - "dedup": { - "operandId": "bfa10d216f843625785d24e6b9d890fb", - "columns": ["user_id", "merchant_id"], - }, - "ds_version": 1, - } + "id":"c898276d34d964b833155b0e36a4ba2b", + "pipelineName":"create_fraud_dataset", + "datasetName":"FraudReportAggregatedDataset", + "dedup":{ + "operandId":"6158406804b946bda0c38a994229e995", + "columns":[ + "user_id", + "merchant_id" + ] + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request @@ -1531,40 +1559,54 @@ def extract_info(df: pd.DataFrame) -> pd.DataFrame: operator_req = sync_request.operators[6] o = { - "id": "0b381d6b2444c390000402aaa4485a26", - "isRoot": True, - "pipelineName": "create_fraud_dataset", - "datasetName": "FraudReportAggregatedDataset", - "aggregate": { - "operandId": "acd519ba5789e767383099d0561e07c8", - "keys": ["merchant_id"], - "specs": [ - { - "count": { - "name": "num_merchant_fraudulent_transactions", - "window": {"forever": {}}, - } - }, - { - "count": { - "name": "num_merchant_fraudulent_transactions_7d", - "window": {"sliding": {"duration": "604800s"}}, - } - }, - { - "quantile": { - "name": "median_transaction_amount", - "window": {"sliding": {"duration": "604800s"}}, - "quantile": 0.5, - "default": 0.0, - "of": "transaction_amount", - "approx": True, - } - }, - ], - }, - "ds_version": 1, - } + "id":"45877eefa2fe6d8dbd5aba2fb07e5cb5", + "isRoot":True, + "pipelineName":"create_fraud_dataset", + "datasetName":"FraudReportAggregatedDataset", + "aggregate":{ + "operandId":"c898276d34d964b833155b0e36a4ba2b", + "keys":[ + "merchant_id" + ], + "specs":[ + { + "count":{ + "name":"num_merchant_fraudulent_transactions", + "window":{ + "forever":{ + + } + } + } + }, + { + "count":{ + "name":"num_merchant_fraudulent_transactions_7d", + "window":{ + "sliding":{ + "duration":"604800s" + } + } + } + }, + { + "quantile":{ + "of":"transaction_amount", + "name":"median_transaction_amount", + "window":{ + "sliding":{ + "duration":"604800s" + } + }, + "default":0.0, + "quantile":0.5, + "approx":True + } + } + ] + }, + "dsVersion":1 + } expected_operator_request = ParseDict(o, ds_proto.Operator()) assert operator_req == expected_operator_request, error_message( operator_req, expected_operator_request diff --git a/fennel/gen/auth_pb2.py b/fennel/gen/auth_pb2.py index 5fb3361ee..c51bec9ca 100644 --- a/fennel/gen/auth_pb2.py +++ b/fennel/gen/auth_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: auth.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/connector_pb2.py b/fennel/gen/connector_pb2.py index 64b76fb79..7a0af5d09 100644 --- a/fennel/gen/connector_pb2.py +++ b/fennel/gen/connector_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: connector.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/dataset_pb2.py b/fennel/gen/dataset_pb2.py index 3fd621362..fe633b2be 100644 --- a/fennel/gen/dataset_pb2.py +++ b/fennel/gen/dataset_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: dataset.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,7 +21,7 @@ import fennel.gen.expr_pb2 as expr__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rdataset.proto\x12\x14\x66\x65nnel.proto.dataset\x1a\x1egoogle/protobuf/duration.proto\x1a\x0emetadata.proto\x1a\x0cpycode.proto\x1a\x0cschema.proto\x1a\nspec.proto\x1a\x0cwindow.proto\x1a\nexpr.proto\"\xe5\x03\n\x0b\x43oreDataset\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\x08metadata\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12/\n\x08\x64sschema\x18\x03 \x01(\x0b\x32\x1d.fennel.proto.schema.DSSchema\x12*\n\x07history\x18\x04 \x01(\x0b\x32\x19.google.protobuf.Duration\x12,\n\tretention\x18\x05 \x01(\x0b\x32\x19.google.protobuf.Duration\x12L\n\x0e\x66ield_metadata\x18\x06 \x03(\x0b\x32\x34.fennel.proto.dataset.CoreDataset.FieldMetadataEntry\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x19\n\x11is_source_dataset\x18\x08 \x01(\x08\x12\x0f\n\x07version\x18\t \x01(\r\x12\x0c\n\x04tags\x18\n \x03(\t\x1aU\n\x12\x46ieldMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12.\n\x05value\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata:\x02\x38\x01\"Q\n\x08OnDemand\x12\x1c\n\x14\x66unction_source_code\x18\x01 \x01(\t\x12\x10\n\x08\x66unction\x18\x02 \x01(\x0c\x12\x15\n\rexpires_after\x18\x03 \x01(\x03\"\xd2\x01\n\x08Pipeline\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\x12\x11\n\tsignature\x18\x03 \x01(\t\x12\x31\n\x08metadata\x18\x04 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x1b\n\x13input_dataset_names\x18\x05 \x03(\t\x12\x12\n\nds_version\x18\x06 \x01(\r\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\"\x8f\x08\n\x08Operator\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0f\n\x07is_root\x18\x02 \x01(\x08\x12\x15\n\rpipeline_name\x18\x03 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x04 \x01(\t\x12\x12\n\nds_version\x18\x14 \x01(\r\x12\x34\n\taggregate\x18\x05 \x01(\x0b\x32\x1f.fennel.proto.dataset.AggregateH\x00\x12*\n\x04join\x18\x06 \x01(\x0b\x32\x1a.fennel.proto.dataset.JoinH\x00\x12\x34\n\ttransform\x18\x07 \x01(\x0b\x32\x1f.fennel.proto.dataset.TransformH\x00\x12,\n\x05union\x18\x08 \x01(\x0b\x32\x1b.fennel.proto.dataset.UnionH\x00\x12.\n\x06\x66ilter\x18\t \x01(\x0b\x32\x1c.fennel.proto.dataset.FilterH\x00\x12\x37\n\x0b\x64\x61taset_ref\x18\n \x01(\x0b\x32 .fennel.proto.dataset.DatasetRefH\x00\x12.\n\x06rename\x18\x0c \x01(\x0b\x32\x1c.fennel.proto.dataset.RenameH\x00\x12*\n\x04\x64rop\x18\r \x01(\x0b\x32\x1a.fennel.proto.dataset.DropH\x00\x12\x30\n\x07\x65xplode\x18\x0e \x01(\x0b\x32\x1d.fennel.proto.dataset.ExplodeH\x00\x12,\n\x05\x64\x65\x64up\x18\x0f \x01(\x0b\x32\x1b.fennel.proto.dataset.DedupH\x00\x12,\n\x05\x66irst\x18\x10 \x01(\x0b\x32\x1b.fennel.proto.dataset.FirstH\x00\x12.\n\x06\x61ssign\x18\x11 \x01(\x0b\x32\x1c.fennel.proto.dataset.AssignH\x00\x12\x32\n\x08\x64ropnull\x18\x12 \x01(\x0b\x32\x1e.fennel.proto.dataset.DropnullH\x00\x12:\n\x06window\x18\x13 \x01(\x0b\x32(.fennel.proto.dataset.WindowOperatorKindH\x00\x12.\n\x06latest\x18\x15 \x01(\x0b\x32\x1c.fennel.proto.dataset.LatestH\x00\x12\x34\n\tchangelog\x18\x16 \x01(\x0b\x32\x1f.fennel.proto.dataset.ChangelogH\x00\x12\x37\n\x0b\x61ssign_expr\x18\x17 \x01(\x0b\x32 .fennel.proto.dataset.AssignExprH\x00\x12\x37\n\x0b\x66ilter_expr\x18\x18 \x01(\x0b\x32 .fennel.proto.dataset.FilterExprH\x00\x12\x0c\n\x04name\x18\x0b \x01(\tB\x06\n\x04kind\"\xc7\x01\n\tAggregate\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0c\n\x04keys\x18\x02 \x03(\t\x12)\n\x05specs\x18\x03 \x03(\x0b\x32\x1a.fennel.proto.spec.PreSpec\x12\x12\n\x05\x61long\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x39\n\remit_strategy\x18\x06 \x01(\x0e\x32\".fennel.proto.dataset.EmitStrategy\x12\x14\n\x0coperand_name\x18\x04 \x01(\tB\x08\n\x06_along\"\xa2\x03\n\x04Join\x12\x16\n\x0elhs_operand_id\x18\x01 \x01(\t\x12\x1c\n\x14rhs_dsref_operand_id\x18\x02 \x01(\t\x12.\n\x02on\x18\x03 \x03(\x0b\x32\".fennel.proto.dataset.Join.OnEntry\x12\x32\n\nwithin_low\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationH\x00\x88\x01\x01\x12\x33\n\x0bwithin_high\x18\x07 \x01(\x0b\x32\x19.google.protobuf.DurationH\x01\x88\x01\x01\x12\x18\n\x10lhs_operand_name\x18\x04 \x01(\t\x12\x1e\n\x16rhs_dsref_operand_name\x18\x05 \x01(\t\x12+\n\x03how\x18\x08 \x01(\x0e\x32\x1e.fennel.proto.dataset.Join.How\x1a)\n\x07OnEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x1a\n\x03How\x12\x08\n\x04Left\x10\x00\x12\t\n\x05Inner\x10\x01\x42\r\n\x0b_within_lowB\x0e\n\x0c_within_high\"\xed\x01\n\tTransform\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12;\n\x06schema\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.Transform.SchemaEntry\x12+\n\x06pycode\x18\x03 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x14\n\x0coperand_name\x18\x04 \x01(\t\x1aL\n\x0bSchemaEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12,\n\x05value\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType:\x02\x38\x01\"]\n\nFilterExpr\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12%\n\x04\x65xpr\x18\x02 \x01(\x0b\x32\x17.fennel.proto.expr.Expr\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"_\n\x06\x46ilter\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12+\n\x06pycode\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xa8\x01\n\x06\x41ssign\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12+\n\x06pycode\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x13\n\x0b\x63olumn_name\x18\x03 \x01(\t\x12\x32\n\x0boutput_type\x18\x04 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType\x12\x14\n\x0coperand_name\x18\x05 \x01(\t\"\xd5\x02\n\nAssignExpr\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12:\n\x05\x65xprs\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.AssignExpr.ExprsEntry\x12G\n\x0coutput_types\x18\x03 \x03(\x0b\x32\x31.fennel.proto.dataset.AssignExpr.OutputTypesEntry\x12\x14\n\x0coperand_name\x18\x05 \x01(\t\x1a\x45\n\nExprsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12&\n\x05value\x18\x02 \x01(\x0b\x32\x17.fennel.proto.expr.Expr:\x02\x38\x01\x1aQ\n\x10OutputTypesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12,\n\x05value\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType:\x02\x38\x01\"E\n\x08\x44ropnull\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"B\n\x04\x44rop\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x10\n\x08\x64ropcols\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xa5\x01\n\x06Rename\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12?\n\ncolumn_map\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.Rename.ColumnMapEntry\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\x1a\x30\n\x0e\x43olumnMapEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"3\n\x05Union\x12\x13\n\x0boperand_ids\x18\x01 \x03(\t\x12\x15\n\roperand_names\x18\x02 \x03(\t\"B\n\x05\x44\x65\x64up\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"D\n\x07\x45xplode\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"=\n\x05\x46irst\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\n\n\x02\x62y\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\">\n\x06Latest\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\n\n\x02\x62y\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"L\n\tChangelog\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x15\n\rdelete_column\x18\x02 \x01(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xcb\x01\n\x12WindowOperatorKind\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x30\n\x0bwindow_type\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.window.Window\x12\n\n\x02\x62y\x18\x03 \x03(\t\x12\r\n\x05\x66ield\x18\x04 \x01(\t\x12\x32\n\x07summary\x18\x06 \x01(\x0b\x32\x1c.fennel.proto.window.SummaryH\x00\x88\x01\x01\x12\x14\n\x0coperand_name\x18\x05 \x01(\tB\n\n\x08_summary\",\n\nDatasetRef\x12\x1e\n\x16referring_dataset_name\x18\x01 \x01(\t\"\x80\x02\n\x08\x44\x61taflow\x12\x16\n\x0c\x64\x61taset_name\x18\x01 \x01(\tH\x00\x12L\n\x11pipeline_dataflow\x18\x02 \x01(\x0b\x32/.fennel.proto.dataset.Dataflow.PipelineDataflowH\x00\x12\x0c\n\x04tags\x18\x03 \x03(\t\x1ax\n\x10PipelineDataflow\x12\x14\n\x0c\x64\x61taset_name\x18\x01 \x01(\t\x12\x15\n\rpipeline_name\x18\x02 \x01(\t\x12\x37\n\x0finput_dataflows\x18\x03 \x03(\x0b\x32\x1e.fennel.proto.dataset.DataflowB\x06\n\x04kind\"\x9c\x01\n\x10PipelineLineages\x12\x14\n\x0c\x64\x61taset_name\x18\x01 \x01(\t\x12\x15\n\rpipeline_name\x18\x02 \x01(\t\x12=\n\x0einput_datasets\x18\x03 \x03(\x0b\x32%.fennel.proto.dataset.DatasetLineages\x12\x0e\n\x06\x61\x63tive\x18\x04 \x01(\x08\x12\x0c\n\x04tags\x18\x05 \x03(\t\"\\\n\x17\x44\x61tasetPipelineLineages\x12\x41\n\x11pipeline_lineages\x18\x02 \x03(\x0b\x32&.fennel.proto.dataset.PipelineLineages\"\x8b\x01\n\x0f\x44\x61tasetLineages\x12\x18\n\x0esource_dataset\x18\x01 \x01(\tH\x00\x12H\n\x0f\x64\x65rived_dataset\x18\x02 \x01(\x0b\x32-.fennel.proto.dataset.DatasetPipelineLineagesH\x00\x12\x0c\n\x04tags\x18\x03 \x03(\tB\x06\n\x04kind*$\n\x0c\x45mitStrategy\x12\t\n\x05\x45\x61ger\x10\x00\x12\t\n\x05\x46inal\x10\x01\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rdataset.proto\x12\x14\x66\x65nnel.proto.dataset\x1a\x1egoogle/protobuf/duration.proto\x1a\x0emetadata.proto\x1a\x0cpycode.proto\x1a\x0cschema.proto\x1a\nspec.proto\x1a\x0cwindow.proto\x1a\nexpr.proto\"\xe5\x03\n\x0b\x43oreDataset\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\x08metadata\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12/\n\x08\x64sschema\x18\x03 \x01(\x0b\x32\x1d.fennel.proto.schema.DSSchema\x12*\n\x07history\x18\x04 \x01(\x0b\x32\x19.google.protobuf.Duration\x12,\n\tretention\x18\x05 \x01(\x0b\x32\x19.google.protobuf.Duration\x12L\n\x0e\x66ield_metadata\x18\x06 \x03(\x0b\x32\x34.fennel.proto.dataset.CoreDataset.FieldMetadataEntry\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x19\n\x11is_source_dataset\x18\x08 \x01(\x08\x12\x0f\n\x07version\x18\t \x01(\r\x12\x0c\n\x04tags\x18\n \x03(\t\x1aU\n\x12\x46ieldMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12.\n\x05value\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata:\x02\x38\x01\"Q\n\x08OnDemand\x12\x1c\n\x14\x66unction_source_code\x18\x01 \x01(\t\x12\x10\n\x08\x66unction\x18\x02 \x01(\x0c\x12\x15\n\rexpires_after\x18\x03 \x01(\x03\"\xd2\x01\n\x08Pipeline\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\x12\x11\n\tsignature\x18\x03 \x01(\t\x12\x31\n\x08metadata\x18\x04 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x1b\n\x13input_dataset_names\x18\x05 \x03(\t\x12\x12\n\nds_version\x18\x06 \x01(\r\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\"\x8f\x08\n\x08Operator\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0f\n\x07is_root\x18\x02 \x01(\x08\x12\x15\n\rpipeline_name\x18\x03 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x04 \x01(\t\x12\x12\n\nds_version\x18\x14 \x01(\r\x12\x34\n\taggregate\x18\x05 \x01(\x0b\x32\x1f.fennel.proto.dataset.AggregateH\x00\x12*\n\x04join\x18\x06 \x01(\x0b\x32\x1a.fennel.proto.dataset.JoinH\x00\x12\x34\n\ttransform\x18\x07 \x01(\x0b\x32\x1f.fennel.proto.dataset.TransformH\x00\x12,\n\x05union\x18\x08 \x01(\x0b\x32\x1b.fennel.proto.dataset.UnionH\x00\x12.\n\x06\x66ilter\x18\t \x01(\x0b\x32\x1c.fennel.proto.dataset.FilterH\x00\x12\x37\n\x0b\x64\x61taset_ref\x18\n \x01(\x0b\x32 .fennel.proto.dataset.DatasetRefH\x00\x12.\n\x06rename\x18\x0c \x01(\x0b\x32\x1c.fennel.proto.dataset.RenameH\x00\x12*\n\x04\x64rop\x18\r \x01(\x0b\x32\x1a.fennel.proto.dataset.DropH\x00\x12\x30\n\x07\x65xplode\x18\x0e \x01(\x0b\x32\x1d.fennel.proto.dataset.ExplodeH\x00\x12,\n\x05\x64\x65\x64up\x18\x0f \x01(\x0b\x32\x1b.fennel.proto.dataset.DedupH\x00\x12,\n\x05\x66irst\x18\x10 \x01(\x0b\x32\x1b.fennel.proto.dataset.FirstH\x00\x12.\n\x06\x61ssign\x18\x11 \x01(\x0b\x32\x1c.fennel.proto.dataset.AssignH\x00\x12\x32\n\x08\x64ropnull\x18\x12 \x01(\x0b\x32\x1e.fennel.proto.dataset.DropnullH\x00\x12:\n\x06window\x18\x13 \x01(\x0b\x32(.fennel.proto.dataset.WindowOperatorKindH\x00\x12.\n\x06latest\x18\x15 \x01(\x0b\x32\x1c.fennel.proto.dataset.LatestH\x00\x12\x34\n\tchangelog\x18\x16 \x01(\x0b\x32\x1f.fennel.proto.dataset.ChangelogH\x00\x12\x37\n\x0b\x61ssign_expr\x18\x17 \x01(\x0b\x32 .fennel.proto.dataset.AssignExprH\x00\x12\x37\n\x0b\x66ilter_expr\x18\x18 \x01(\x0b\x32 .fennel.proto.dataset.FilterExprH\x00\x12\x0c\n\x04name\x18\x0b \x01(\tB\x06\n\x04kind\"\xc7\x01\n\tAggregate\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0c\n\x04keys\x18\x02 \x03(\t\x12)\n\x05specs\x18\x03 \x03(\x0b\x32\x1a.fennel.proto.spec.PreSpec\x12\x12\n\x05\x61long\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x39\n\remit_strategy\x18\x06 \x01(\x0e\x32\".fennel.proto.dataset.EmitStrategy\x12\x14\n\x0coperand_name\x18\x04 \x01(\tB\x08\n\x06_along\"\xb5\x03\n\x04Join\x12\x16\n\x0elhs_operand_id\x18\x01 \x01(\t\x12\x1c\n\x14rhs_dsref_operand_id\x18\x02 \x01(\t\x12.\n\x02on\x18\x03 \x03(\x0b\x32\".fennel.proto.dataset.Join.OnEntry\x12\x32\n\nwithin_low\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationH\x00\x88\x01\x01\x12\x33\n\x0bwithin_high\x18\x07 \x01(\x0b\x32\x19.google.protobuf.DurationH\x01\x88\x01\x01\x12\x18\n\x10lhs_operand_name\x18\x04 \x01(\t\x12\x1e\n\x16rhs_dsref_operand_name\x18\x05 \x01(\t\x12+\n\x03how\x18\x08 \x01(\x0e\x32\x1e.fennel.proto.dataset.Join.How\x12\x11\n\tbroadcast\x18\t \x01(\x08\x1a)\n\x07OnEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x1a\n\x03How\x12\x08\n\x04Left\x10\x00\x12\t\n\x05Inner\x10\x01\x42\r\n\x0b_within_lowB\x0e\n\x0c_within_high\"\xed\x01\n\tTransform\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12;\n\x06schema\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.Transform.SchemaEntry\x12+\n\x06pycode\x18\x03 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x14\n\x0coperand_name\x18\x04 \x01(\t\x1aL\n\x0bSchemaEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12,\n\x05value\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType:\x02\x38\x01\"]\n\nFilterExpr\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12%\n\x04\x65xpr\x18\x02 \x01(\x0b\x32\x17.fennel.proto.expr.Expr\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"_\n\x06\x46ilter\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12+\n\x06pycode\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xa8\x01\n\x06\x41ssign\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12+\n\x06pycode\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x13\n\x0b\x63olumn_name\x18\x03 \x01(\t\x12\x32\n\x0boutput_type\x18\x04 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType\x12\x14\n\x0coperand_name\x18\x05 \x01(\t\"\xd5\x02\n\nAssignExpr\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12:\n\x05\x65xprs\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.AssignExpr.ExprsEntry\x12G\n\x0coutput_types\x18\x03 \x03(\x0b\x32\x31.fennel.proto.dataset.AssignExpr.OutputTypesEntry\x12\x14\n\x0coperand_name\x18\x05 \x01(\t\x1a\x45\n\nExprsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12&\n\x05value\x18\x02 \x01(\x0b\x32\x17.fennel.proto.expr.Expr:\x02\x38\x01\x1aQ\n\x10OutputTypesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12,\n\x05value\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType:\x02\x38\x01\"E\n\x08\x44ropnull\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"B\n\x04\x44rop\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x10\n\x08\x64ropcols\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xa5\x01\n\x06Rename\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12?\n\ncolumn_map\x18\x02 \x03(\x0b\x32+.fennel.proto.dataset.Rename.ColumnMapEntry\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\x1a\x30\n\x0e\x43olumnMapEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"3\n\x05Union\x12\x13\n\x0boperand_ids\x18\x01 \x03(\t\x12\x15\n\roperand_names\x18\x02 \x03(\t\"B\n\x05\x44\x65\x64up\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"D\n\x07\x45xplode\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63olumns\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"=\n\x05\x46irst\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\n\n\x02\x62y\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\">\n\x06Latest\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\n\n\x02\x62y\x18\x02 \x03(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"L\n\tChangelog\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x15\n\rdelete_column\x18\x02 \x01(\t\x12\x14\n\x0coperand_name\x18\x03 \x01(\t\"\xcb\x01\n\x12WindowOperatorKind\x12\x12\n\noperand_id\x18\x01 \x01(\t\x12\x30\n\x0bwindow_type\x18\x02 \x01(\x0b\x32\x1b.fennel.proto.window.Window\x12\n\n\x02\x62y\x18\x03 \x03(\t\x12\r\n\x05\x66ield\x18\x04 \x01(\t\x12\x32\n\x07summary\x18\x06 \x01(\x0b\x32\x1c.fennel.proto.window.SummaryH\x00\x88\x01\x01\x12\x14\n\x0coperand_name\x18\x05 \x01(\tB\n\n\x08_summary\",\n\nDatasetRef\x12\x1e\n\x16referring_dataset_name\x18\x01 \x01(\t\"\x80\x02\n\x08\x44\x61taflow\x12\x16\n\x0c\x64\x61taset_name\x18\x01 \x01(\tH\x00\x12L\n\x11pipeline_dataflow\x18\x02 \x01(\x0b\x32/.fennel.proto.dataset.Dataflow.PipelineDataflowH\x00\x12\x0c\n\x04tags\x18\x03 \x03(\t\x1ax\n\x10PipelineDataflow\x12\x14\n\x0c\x64\x61taset_name\x18\x01 \x01(\t\x12\x15\n\rpipeline_name\x18\x02 \x01(\t\x12\x37\n\x0finput_dataflows\x18\x03 \x03(\x0b\x32\x1e.fennel.proto.dataset.DataflowB\x06\n\x04kind\"\x9c\x01\n\x10PipelineLineages\x12\x14\n\x0c\x64\x61taset_name\x18\x01 \x01(\t\x12\x15\n\rpipeline_name\x18\x02 \x01(\t\x12=\n\x0einput_datasets\x18\x03 \x03(\x0b\x32%.fennel.proto.dataset.DatasetLineages\x12\x0e\n\x06\x61\x63tive\x18\x04 \x01(\x08\x12\x0c\n\x04tags\x18\x05 \x03(\t\"\\\n\x17\x44\x61tasetPipelineLineages\x12\x41\n\x11pipeline_lineages\x18\x02 \x03(\x0b\x32&.fennel.proto.dataset.PipelineLineages\"\x8b\x01\n\x0f\x44\x61tasetLineages\x12\x18\n\x0esource_dataset\x18\x01 \x01(\tH\x00\x12H\n\x0f\x64\x65rived_dataset\x18\x02 \x01(\x0b\x32-.fennel.proto.dataset.DatasetPipelineLineagesH\x00\x12\x0c\n\x04tags\x18\x03 \x03(\tB\x06\n\x04kind*$\n\x0c\x45mitStrategy\x12\t\n\x05\x45\x61ger\x10\x00\x12\t\n\x05\x46inal\x10\x01\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -39,8 +40,8 @@ _globals['_ASSIGNEXPR_OUTPUTTYPESENTRY']._serialized_options = b'8\001' _globals['_RENAME_COLUMNMAPENTRY']._options = None _globals['_RENAME_COLUMNMAPENTRY']._serialized_options = b'8\001' - _globals['_EMITSTRATEGY']._serialized_start=5158 - _globals['_EMITSTRATEGY']._serialized_end=5194 + _globals['_EMITSTRATEGY']._serialized_start=5177 + _globals['_EMITSTRATEGY']._serialized_end=5213 _globals['_COREDATASET']._serialized_start=154 _globals['_COREDATASET']._serialized_end=639 _globals['_COREDATASET_FIELDMETADATAENTRY']._serialized_start=554 @@ -54,59 +55,59 @@ _globals['_AGGREGATE']._serialized_start=1980 _globals['_AGGREGATE']._serialized_end=2179 _globals['_JOIN']._serialized_start=2182 - _globals['_JOIN']._serialized_end=2600 - _globals['_JOIN_ONENTRY']._serialized_start=2500 - _globals['_JOIN_ONENTRY']._serialized_end=2541 - _globals['_JOIN_HOW']._serialized_start=2543 - _globals['_JOIN_HOW']._serialized_end=2569 - _globals['_TRANSFORM']._serialized_start=2603 - _globals['_TRANSFORM']._serialized_end=2840 - _globals['_TRANSFORM_SCHEMAENTRY']._serialized_start=2764 - _globals['_TRANSFORM_SCHEMAENTRY']._serialized_end=2840 - _globals['_FILTEREXPR']._serialized_start=2842 - _globals['_FILTEREXPR']._serialized_end=2935 - _globals['_FILTER']._serialized_start=2937 - _globals['_FILTER']._serialized_end=3032 - _globals['_ASSIGN']._serialized_start=3035 - _globals['_ASSIGN']._serialized_end=3203 - _globals['_ASSIGNEXPR']._serialized_start=3206 - _globals['_ASSIGNEXPR']._serialized_end=3547 - _globals['_ASSIGNEXPR_EXPRSENTRY']._serialized_start=3395 - _globals['_ASSIGNEXPR_EXPRSENTRY']._serialized_end=3464 - _globals['_ASSIGNEXPR_OUTPUTTYPESENTRY']._serialized_start=3466 - _globals['_ASSIGNEXPR_OUTPUTTYPESENTRY']._serialized_end=3547 - _globals['_DROPNULL']._serialized_start=3549 - _globals['_DROPNULL']._serialized_end=3618 - _globals['_DROP']._serialized_start=3620 - _globals['_DROP']._serialized_end=3686 - _globals['_RENAME']._serialized_start=3689 - _globals['_RENAME']._serialized_end=3854 - _globals['_RENAME_COLUMNMAPENTRY']._serialized_start=3806 - _globals['_RENAME_COLUMNMAPENTRY']._serialized_end=3854 - _globals['_UNION']._serialized_start=3856 - _globals['_UNION']._serialized_end=3907 - _globals['_DEDUP']._serialized_start=3909 - _globals['_DEDUP']._serialized_end=3975 - _globals['_EXPLODE']._serialized_start=3977 - _globals['_EXPLODE']._serialized_end=4045 - _globals['_FIRST']._serialized_start=4047 - _globals['_FIRST']._serialized_end=4108 - _globals['_LATEST']._serialized_start=4110 - _globals['_LATEST']._serialized_end=4172 - _globals['_CHANGELOG']._serialized_start=4174 - _globals['_CHANGELOG']._serialized_end=4250 - _globals['_WINDOWOPERATORKIND']._serialized_start=4253 - _globals['_WINDOWOPERATORKIND']._serialized_end=4456 - _globals['_DATASETREF']._serialized_start=4458 - _globals['_DATASETREF']._serialized_end=4502 - _globals['_DATAFLOW']._serialized_start=4505 - _globals['_DATAFLOW']._serialized_end=4761 - _globals['_DATAFLOW_PIPELINEDATAFLOW']._serialized_start=4633 - _globals['_DATAFLOW_PIPELINEDATAFLOW']._serialized_end=4753 - _globals['_PIPELINELINEAGES']._serialized_start=4764 - _globals['_PIPELINELINEAGES']._serialized_end=4920 - _globals['_DATASETPIPELINELINEAGES']._serialized_start=4922 - _globals['_DATASETPIPELINELINEAGES']._serialized_end=5014 - _globals['_DATASETLINEAGES']._serialized_start=5017 - _globals['_DATASETLINEAGES']._serialized_end=5156 + _globals['_JOIN']._serialized_end=2619 + _globals['_JOIN_ONENTRY']._serialized_start=2519 + _globals['_JOIN_ONENTRY']._serialized_end=2560 + _globals['_JOIN_HOW']._serialized_start=2562 + _globals['_JOIN_HOW']._serialized_end=2588 + _globals['_TRANSFORM']._serialized_start=2622 + _globals['_TRANSFORM']._serialized_end=2859 + _globals['_TRANSFORM_SCHEMAENTRY']._serialized_start=2783 + _globals['_TRANSFORM_SCHEMAENTRY']._serialized_end=2859 + _globals['_FILTEREXPR']._serialized_start=2861 + _globals['_FILTEREXPR']._serialized_end=2954 + _globals['_FILTER']._serialized_start=2956 + _globals['_FILTER']._serialized_end=3051 + _globals['_ASSIGN']._serialized_start=3054 + _globals['_ASSIGN']._serialized_end=3222 + _globals['_ASSIGNEXPR']._serialized_start=3225 + _globals['_ASSIGNEXPR']._serialized_end=3566 + _globals['_ASSIGNEXPR_EXPRSENTRY']._serialized_start=3414 + _globals['_ASSIGNEXPR_EXPRSENTRY']._serialized_end=3483 + _globals['_ASSIGNEXPR_OUTPUTTYPESENTRY']._serialized_start=3485 + _globals['_ASSIGNEXPR_OUTPUTTYPESENTRY']._serialized_end=3566 + _globals['_DROPNULL']._serialized_start=3568 + _globals['_DROPNULL']._serialized_end=3637 + _globals['_DROP']._serialized_start=3639 + _globals['_DROP']._serialized_end=3705 + _globals['_RENAME']._serialized_start=3708 + _globals['_RENAME']._serialized_end=3873 + _globals['_RENAME_COLUMNMAPENTRY']._serialized_start=3825 + _globals['_RENAME_COLUMNMAPENTRY']._serialized_end=3873 + _globals['_UNION']._serialized_start=3875 + _globals['_UNION']._serialized_end=3926 + _globals['_DEDUP']._serialized_start=3928 + _globals['_DEDUP']._serialized_end=3994 + _globals['_EXPLODE']._serialized_start=3996 + _globals['_EXPLODE']._serialized_end=4064 + _globals['_FIRST']._serialized_start=4066 + _globals['_FIRST']._serialized_end=4127 + _globals['_LATEST']._serialized_start=4129 + _globals['_LATEST']._serialized_end=4191 + _globals['_CHANGELOG']._serialized_start=4193 + _globals['_CHANGELOG']._serialized_end=4269 + _globals['_WINDOWOPERATORKIND']._serialized_start=4272 + _globals['_WINDOWOPERATORKIND']._serialized_end=4475 + _globals['_DATASETREF']._serialized_start=4477 + _globals['_DATASETREF']._serialized_end=4521 + _globals['_DATAFLOW']._serialized_start=4524 + _globals['_DATAFLOW']._serialized_end=4780 + _globals['_DATAFLOW_PIPELINEDATAFLOW']._serialized_start=4652 + _globals['_DATAFLOW_PIPELINEDATAFLOW']._serialized_end=4772 + _globals['_PIPELINELINEAGES']._serialized_start=4783 + _globals['_PIPELINELINEAGES']._serialized_end=4939 + _globals['_DATASETPIPELINELINEAGES']._serialized_start=4941 + _globals['_DATASETPIPELINELINEAGES']._serialized_end=5033 + _globals['_DATASETLINEAGES']._serialized_start=5036 + _globals['_DATASETLINEAGES']._serialized_end=5175 # @@protoc_insertion_point(module_scope) diff --git a/fennel/gen/dataset_pb2.pyi b/fennel/gen/dataset_pb2.pyi index 4a61e5a84..4c4da1118 100644 --- a/fennel/gen/dataset_pb2.pyi +++ b/fennel/gen/dataset_pb2.pyi @@ -370,6 +370,7 @@ class Join(google.protobuf.message.Message): LHS_OPERAND_NAME_FIELD_NUMBER: builtins.int RHS_DSREF_OPERAND_NAME_FIELD_NUMBER: builtins.int HOW_FIELD_NUMBER: builtins.int + BROADCAST_FIELD_NUMBER: builtins.int lhs_operand_id: builtins.str rhs_dsref_operand_id: builtins.str """RHS of a JOIN can only be a dataset, here it refers to the DSRef operator""" @@ -386,6 +387,7 @@ class Join(google.protobuf.message.Message): """ rhs_dsref_operand_name: builtins.str how: global___Join.How.ValueType + broadcast: builtins.bool def __init__( self, *, @@ -397,9 +399,10 @@ class Join(google.protobuf.message.Message): lhs_operand_name: builtins.str = ..., rhs_dsref_operand_name: builtins.str = ..., how: global___Join.How.ValueType = ..., + broadcast: builtins.bool = ..., ) -> None: ... def HasField(self, field_name: typing_extensions.Literal["_within_high", b"_within_high", "_within_low", b"_within_low", "within_high", b"within_high", "within_low", b"within_low"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["_within_high", b"_within_high", "_within_low", b"_within_low", "how", b"how", "lhs_operand_id", b"lhs_operand_id", "lhs_operand_name", b"lhs_operand_name", "on", b"on", "rhs_dsref_operand_id", b"rhs_dsref_operand_id", "rhs_dsref_operand_name", b"rhs_dsref_operand_name", "within_high", b"within_high", "within_low", b"within_low"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["_within_high", b"_within_high", "_within_low", b"_within_low", "broadcast", b"broadcast", "how", b"how", "lhs_operand_id", b"lhs_operand_id", "lhs_operand_name", b"lhs_operand_name", "on", b"on", "rhs_dsref_operand_id", b"rhs_dsref_operand_id", "rhs_dsref_operand_name", b"rhs_dsref_operand_name", "within_high", b"within_high", "within_low", b"within_low"]) -> None: ... @typing.overload def WhichOneof(self, oneof_group: typing_extensions.Literal["_within_high", b"_within_high"]) -> typing_extensions.Literal["within_high"] | None: ... @typing.overload diff --git a/fennel/gen/expectations_pb2.py b/fennel/gen/expectations_pb2.py index 67ed27576..a149c87e1 100644 --- a/fennel/gen/expectations_pb2.py +++ b/fennel/gen/expectations_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: expectations.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/expr_pb2.py b/fennel/gen/expr_pb2.py index faf568c8a..fdc2dfde8 100644 --- a/fennel/gen/expr_pb2.py +++ b/fennel/gen/expr_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: expr.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/featureset_pb2.py b/fennel/gen/featureset_pb2.py index b72b61600..4df083d90 100644 --- a/fennel/gen/featureset_pb2.py +++ b/fennel/gen/featureset_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: featureset.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -17,15 +18,15 @@ import fennel.gen.expr_pb2 as expr__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x66\x65\x61tureset.proto\x12\x17\x66\x65nnel.proto.featureset\x1a\x0emetadata.proto\x1a\x0cschema.proto\x1a\x0cpycode.proto\x1a\nexpr.proto\"\x8c\x01\n\x0e\x43oreFeatureset\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\x08metadata\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12+\n\x06pycode\x18\x03 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x0c\n\x04tags\x18\x04 \x03(\t\"\xa0\x01\n\x07\x46\x65\x61ture\x12\x0c\n\x04name\x18\x01 \x01(\t\x12,\n\x05\x64type\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType\x12\x31\n\x08metadata\x18\x03 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x04 \x01(\t\x12\x0c\n\x04tags\x18\x05 \x03(\t\"S\n\x0f\x46ieldLookupInfo\x12)\n\x05\x66ield\x18\x01 \x01(\x0b\x32\x1a.fennel.proto.schema.Field\x12\x15\n\rdefault_value\x18\x03 \x01(\t\"\xc7\x03\n\tExtractor\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08\x64\x61tasets\x18\x02 \x03(\t\x12.\n\x06inputs\x18\x03 \x03(\x0b\x32\x1e.fennel.proto.featureset.Input\x12\x10\n\x08\x66\x65\x61tures\x18\x04 \x03(\t\x12\x31\n\x08metadata\x18\x05 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x0f\n\x07version\x18\x06 \x01(\x05\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x08 \x01(\t\x12>\n\x0e\x65xtractor_type\x18\t \x01(\x0e\x32&.fennel.proto.featureset.ExtractorType\x12>\n\nfield_info\x18\n \x01(\x0b\x32(.fennel.proto.featureset.FieldLookupInfoH\x00\x12%\n\x04\x65xpr\x18\x0c \x01(\x0b\x32\x17.fennel.proto.expr.Expr\x12\x0c\n\x04tags\x18\x0b \x03(\tB\x18\n\x16\x64\x65rived_extractor_info\"s\n\x05Input\x12\x37\n\x07\x66\x65\x61ture\x18\x01 \x01(\x0b\x32&.fennel.proto.featureset.Input.Feature\x1a\x31\n\x07\x46\x65\x61ture\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\"\xad\x01\n\x05Model\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x30\n\x06inputs\x18\x02 \x03(\x0b\x32 .fennel.proto.featureset.Feature\x12\x31\n\x07outputs\x18\x03 \x03(\x0b\x32 .fennel.proto.featureset.Feature\x12\x31\n\x08metadata\x18\x04 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata*=\n\rExtractorType\x12\x0b\n\x07PY_FUNC\x10\x00\x12\n\n\x06LOOKUP\x10\x01\x12\t\n\x05\x41LIAS\x10\x02\x12\x08\n\x04\x45XPR\x10\x03\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x66\x65\x61tureset.proto\x12\x17\x66\x65nnel.proto.featureset\x1a\x0emetadata.proto\x1a\x0cschema.proto\x1a\x0cpycode.proto\x1a\nexpr.proto\"\x8c\x01\n\x0e\x43oreFeatureset\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\x08metadata\x18\x02 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12+\n\x06pycode\x18\x03 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x0c\n\x04tags\x18\x04 \x03(\t\"\xa0\x01\n\x07\x46\x65\x61ture\x12\x0c\n\x04name\x18\x01 \x01(\t\x12,\n\x05\x64type\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType\x12\x31\n\x08metadata\x18\x03 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x04 \x01(\t\x12\x0c\n\x04tags\x18\x05 \x03(\t\"S\n\x0f\x46ieldLookupInfo\x12)\n\x05\x66ield\x18\x01 \x01(\x0b\x32\x1a.fennel.proto.schema.Field\x12\x15\n\rdefault_value\x18\x03 \x01(\t\"\xc7\x03\n\tExtractor\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08\x64\x61tasets\x18\x02 \x03(\t\x12.\n\x06inputs\x18\x03 \x03(\x0b\x32\x1e.fennel.proto.featureset.Input\x12\x10\n\x08\x66\x65\x61tures\x18\x04 \x03(\t\x12\x31\n\x08metadata\x18\x05 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata\x12\x0f\n\x07version\x18\x06 \x01(\x05\x12+\n\x06pycode\x18\x07 \x01(\x0b\x32\x1b.fennel.proto.pycode.PyCode\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x08 \x01(\t\x12>\n\x0e\x65xtractor_type\x18\t \x01(\x0e\x32&.fennel.proto.featureset.ExtractorType\x12>\n\nfield_info\x18\n \x01(\x0b\x32(.fennel.proto.featureset.FieldLookupInfoH\x00\x12%\n\x04\x65xpr\x18\x0c \x01(\x0b\x32\x17.fennel.proto.expr.Expr\x12\x0c\n\x04tags\x18\x0b \x03(\tB\x18\n\x16\x64\x65rived_extractor_info\"\xa1\x01\n\x05Input\x12\x37\n\x07\x66\x65\x61ture\x18\x01 \x01(\x0b\x32&.fennel.proto.featureset.Input.Feature\x12,\n\x05\x64type\x18\x02 \x01(\x0b\x32\x1d.fennel.proto.schema.DataType\x1a\x31\n\x07\x46\x65\x61ture\x12\x18\n\x10\x66\x65\x61ture_set_name\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\"\xad\x01\n\x05Model\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x30\n\x06inputs\x18\x02 \x03(\x0b\x32 .fennel.proto.featureset.Feature\x12\x31\n\x07outputs\x18\x03 \x03(\x0b\x32 .fennel.proto.featureset.Feature\x12\x31\n\x08metadata\x18\x04 \x01(\x0b\x32\x1f.fennel.proto.metadata.Metadata*=\n\rExtractorType\x12\x0b\n\x07PY_FUNC\x10\x00\x12\n\n\x06LOOKUP\x10\x01\x12\t\n\x05\x41LIAS\x10\x02\x12\x08\n\x04\x45XPR\x10\x03\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'featureset_pb2', _globals) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None - _globals['_EXTRACTORTYPE']._serialized_start=1243 - _globals['_EXTRACTORTYPE']._serialized_end=1304 + _globals['_EXTRACTORTYPE']._serialized_start=1290 + _globals['_EXTRACTORTYPE']._serialized_end=1351 _globals['_COREFEATURESET']._serialized_start=102 _globals['_COREFEATURESET']._serialized_end=242 _globals['_FEATURE']._serialized_start=245 @@ -34,10 +35,10 @@ _globals['_FIELDLOOKUPINFO']._serialized_end=490 _globals['_EXTRACTOR']._serialized_start=493 _globals['_EXTRACTOR']._serialized_end=948 - _globals['_INPUT']._serialized_start=950 - _globals['_INPUT']._serialized_end=1065 - _globals['_INPUT_FEATURE']._serialized_start=1016 - _globals['_INPUT_FEATURE']._serialized_end=1065 - _globals['_MODEL']._serialized_start=1068 - _globals['_MODEL']._serialized_end=1241 + _globals['_INPUT']._serialized_start=951 + _globals['_INPUT']._serialized_end=1112 + _globals['_INPUT_FEATURE']._serialized_start=1063 + _globals['_INPUT_FEATURE']._serialized_end=1112 + _globals['_MODEL']._serialized_start=1115 + _globals['_MODEL']._serialized_end=1288 # @@protoc_insertion_point(module_scope) diff --git a/fennel/gen/featureset_pb2.pyi b/fennel/gen/featureset_pb2.pyi index e511ac948..d4bfe17f1 100644 --- a/fennel/gen/featureset_pb2.pyi +++ b/fennel/gen/featureset_pb2.pyi @@ -208,15 +208,19 @@ class Input(google.protobuf.message.Message): def ClearField(self, field_name: typing_extensions.Literal["feature_set_name", b"feature_set_name", "name", b"name"]) -> None: ... FEATURE_FIELD_NUMBER: builtins.int + DTYPE_FIELD_NUMBER: builtins.int @property def feature(self) -> global___Input.Feature: ... + @property + def dtype(self) -> schema_pb2.DataType: ... def __init__( self, *, feature: global___Input.Feature | None = ..., + dtype: schema_pb2.DataType | None = ..., ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["feature", b"feature"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["feature", b"feature"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["dtype", b"dtype", "feature", b"feature"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["dtype", b"dtype", "feature", b"feature"]) -> None: ... global___Input = Input diff --git a/fennel/gen/format_pb2.py b/fennel/gen/format_pb2.py index 5e7459a77..a83bd4cd6 100644 --- a/fennel/gen/format_pb2.py +++ b/fennel/gen/format_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: format.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/http_auth_pb2.py b/fennel/gen/http_auth_pb2.py index a51d66082..34797b8dc 100644 --- a/fennel/gen/http_auth_pb2.py +++ b/fennel/gen/http_auth_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: http_auth.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/index_pb2.py b/fennel/gen/index_pb2.py index 9e3863f89..d7cfdffba 100644 --- a/fennel/gen/index_pb2.py +++ b/fennel/gen/index_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: index.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/kinesis_pb2.py b/fennel/gen/kinesis_pb2.py index 520ff7fd2..37fe3cc62 100644 --- a/fennel/gen/kinesis_pb2.py +++ b/fennel/gen/kinesis_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: kinesis.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/metadata_pb2.py b/fennel/gen/metadata_pb2.py index d9d355cc9..82b9ffc47 100644 --- a/fennel/gen/metadata_pb2.py +++ b/fennel/gen/metadata_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: metadata.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/pycode_pb2.py b/fennel/gen/pycode_pb2.py index d17598f79..d53c3edee 100644 --- a/fennel/gen/pycode_pb2.py +++ b/fennel/gen/pycode_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: pycode.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/pycode_pb2.pyi b/fennel/gen/pycode_pb2.pyi index 3ec819c89..9b997c4f8 100644 --- a/fennel/gen/pycode_pb2.pyi +++ b/fennel/gen/pycode_pb2.pyi @@ -100,7 +100,7 @@ class PyCode(google.protobuf.message.Message): global___PyCode = PyCode @typing_extensions.final -class UDcol(google.protobuf.message.Message): +class UDF(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor PYCODE_FIELD_NUMBER: builtins.int diff --git a/fennel/gen/schema_pb2.py b/fennel/gen/schema_pb2.py index e8d3e1501..4f56afb6f 100644 --- a/fennel/gen/schema_pb2.py +++ b/fennel/gen/schema_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: schema.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/schema_registry_pb2.py b/fennel/gen/schema_registry_pb2.py index 5bfb5b171..f1248b253 100644 --- a/fennel/gen/schema_registry_pb2.py +++ b/fennel/gen/schema_registry_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: schema_registry.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/services_pb2.py b/fennel/gen/services_pb2.py index 00770b71a..0bf595aed 100644 --- a/fennel/gen/services_pb2.py +++ b/fennel/gen/services_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: services.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/spec_pb2.py b/fennel/gen/spec_pb2.py index 9063c84fa..d1e3e9d92 100644 --- a/fennel/gen/spec_pb2.py +++ b/fennel/gen/spec_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: spec.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/status_pb2.py b/fennel/gen/status_pb2.py index cdc144a8b..f24662be1 100644 --- a/fennel/gen/status_pb2.py +++ b/fennel/gen/status_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: status.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/fennel/gen/window_pb2.py b/fennel/gen/window_pb2.py index ac2bb8d59..6b51a69dd 100644 --- a/fennel/gen/window_pb2.py +++ b/fennel/gen/window_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: window.proto +# Protobuf Python Version: 4.25.4 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool