Skip to content

Commit

Permalink
Add enum-like class for routine determinism level
Browse files Browse the repository at this point in the history
  • Loading branch information
plamut committed Feb 17, 2021
1 parent 505037c commit d2aeb35
Show file tree
Hide file tree
Showing 7 changed files with 66 additions and 12 deletions.
1 change: 1 addition & 0 deletions docs/reference.rst
Expand Up @@ -110,6 +110,7 @@ Routine
.. autosummary::
:toctree: generated

routine.DeterminismLevel
routine.Routine
routine.RoutineArgument
routine.RoutineReference
Expand Down
2 changes: 2 additions & 0 deletions google/cloud/bigquery/__init__.py
Expand Up @@ -70,6 +70,7 @@
from google.cloud.bigquery.query import StructQueryParameter
from google.cloud.bigquery.query import UDFResource
from google.cloud.bigquery.retry import DEFAULT_RETRY
from google.cloud.bigquery.routine import DeterminismLevel
from google.cloud.bigquery.routine import Routine
from google.cloud.bigquery.routine import RoutineArgument
from google.cloud.bigquery.routine import RoutineReference
Expand Down Expand Up @@ -134,6 +135,7 @@
"Compression",
"CreateDisposition",
"DestinationFormat",
"DeterminismLevel",
"ExternalSourceFormat",
"Encoding",
"QueryPriority",
Expand Down
17 changes: 17 additions & 0 deletions google/cloud/bigquery/enums.py
Expand Up @@ -231,3 +231,20 @@ class WriteDisposition(object):
WRITE_EMPTY = "WRITE_EMPTY"
"""If the table already exists and contains data, a 'duplicate' error is
returned in the job result."""


class DeterminismLevel:
"""Specifies determinism level for JavaScript user-defined functions (UDFs).
https://cloud.google.com/bigquery/docs/reference/rest/v2/routines#DeterminismLevel
"""

DETERMINISM_LEVEL_UNSPECIFIED = "DETERMINISM_LEVEL_UNSPECIFIED"
"""The determinism of the UDF is unspecified."""

DETERMINISTIC = "DETERMINISTIC"
"""The UDF is deterministic, meaning that 2 function calls with the same inputs
always produce the same result, even across 2 query runs."""

NOT_DETERMINISTIC = "NOT_DETERMINISTIC"
"""The UDF is not deterministic."""
29 changes: 29 additions & 0 deletions google/cloud/bigquery/routine/__init__.py
@@ -0,0 +1,29 @@
# Copyright 2015 Google LLC
#
# Licensed 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.

"""User-Defined Routines."""


from google.cloud.bigquery.enums import DeterminismLevel
from google.cloud.bigquery.routine.routine import Routine
from google.cloud.bigquery.routine.routine import RoutineArgument
from google.cloud.bigquery.routine.routine import RoutineReference


__all__ = (
"DeterminismLevel",
"Routine",
"RoutineArgument",
"RoutineReference",
)
File renamed without changes.
2 changes: 1 addition & 1 deletion tests/system/test_client.py
Expand Up @@ -2682,7 +2682,7 @@ def test_create_routine(self):
)
]
routine.body = "return maxValue(arr)"
routine.determinism_level = "DETERMINISTIC"
routine.determinism_level = bigquery.DeterminismLevel.DETERMINISTIC
query_string = "SELECT `{}`([-100.0, 3.14, 100.0, 42.0]) as max_value;".format(
str(routine.reference)
)
Expand Down
27 changes: 16 additions & 11 deletions tests/unit/routine/test_routine.py
Expand Up @@ -18,6 +18,7 @@
import pytest

import google.cloud._helpers
from google.cloud import bigquery
from google.cloud import bigquery_v2


Expand Down Expand Up @@ -73,7 +74,7 @@ def test_ctor_w_properties(target_class):
)
type_ = "SCALAR_FUNCTION"
description = "A routine description."
determinism_level = "NOT_DETERMINISTIC"
determinism_level = bigquery.DeterminismLevel.NOT_DETERMINISTIC

actual_routine = target_class(
routine_id,
Expand All @@ -94,7 +95,9 @@ def test_ctor_w_properties(target_class):
assert actual_routine.return_type == return_type
assert actual_routine.type_ == type_
assert actual_routine.description == description
assert actual_routine.determinism_level == "NOT_DETERMINISTIC"
assert (
actual_routine.determinism_level == bigquery.DeterminismLevel.NOT_DETERMINISTIC
)


def test_from_api_repr(target_class):
Expand Down Expand Up @@ -123,7 +126,7 @@ def test_from_api_repr(target_class):
"routineType": "SCALAR_FUNCTION",
"someNewField": "someValue",
"description": "A routine description.",
"determinismLevel": "DETERMINISTIC",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISTIC,
}
actual_routine = target_class.from_api_repr(resource)

Expand Down Expand Up @@ -214,7 +217,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["arguments"],
{"arguments": [{"name": "x", "dataType": {"typeKind": "INT64"}}]},
Expand All @@ -227,7 +230,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["body"],
{"definitionBody": "x * 3"},
Expand All @@ -240,7 +243,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["language"],
{"language": "SQL"},
Expand All @@ -253,7 +256,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["return_type"],
{"returnType": {"typeKind": "INT64"}},
Expand All @@ -266,7 +269,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["type_"],
{"routineType": "SCALAR_FUNCTION"},
Expand All @@ -279,7 +282,7 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["description"],
{"description": "A routine description."},
Expand All @@ -292,10 +295,12 @@ def test_from_api_repr_w_unknown_fields(target_class):
"returnType": {"typeKind": "INT64"},
"routineType": "SCALAR_FUNCTION",
"description": "A routine description.",
"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED",
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED,
},
["determinism_level"],
{"determinismLevel": "DETERMINISM_LEVEL_UNSPECIFIED"},
{
"determinismLevel": bigquery.DeterminismLevel.DETERMINISM_LEVEL_UNSPECIFIED
},
),
(
{},
Expand Down

0 comments on commit d2aeb35

Please sign in to comment.