Skip to content

Optional flag for subtask submission #29

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
lukasbindreiter wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Optional flag for subtask submission #29

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions tilebox-datasets/tests/test_timeseries.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,11 +24,11 @@
DeleteCollectionRequest,
GetCollectionByNameRequest,
ListCollectionsRequest,
ListCollectionsResponse,
)
from tilebox.datasets.datasets.v1.collections_pb2_grpc import CollectionServiceStub
from tilebox.datasets.datasets.v1.core_pb2 import Collection as CollectionMessage
from tilebox.datasets.datasets.v1.core_pb2 import CollectionInfo as CollectionInfoMessage
from tilebox.datasets.datasets.v1.core_pb2 import CollectionInfos as CollectionInfosMessage
from tilebox.datasets.query.time_interval import (
_EMPTY_TIME_INTERVAL,
TimeInterval,
Expand Down Expand Up @@ -298,9 +298,9 @@ def DeleteCollection(self, req: DeleteCollectionRequest) -> None: # noqa: N802
del self.collections[collection.collection.name]
return

def ListCollections(self, req: ListCollectionsRequest) -> CollectionInfosMessage: # noqa: N802
def ListCollections(self, req: ListCollectionsRequest) -> ListCollectionsResponse: # noqa: N802
_ = req
return CollectionInfosMessage(data=list(self.collections.values()))
return ListCollectionsResponse(data=list(self.collections.values()), owned_collections=len(self.collections))


class CollectionCRUDOperations(RuleBasedStateMachine):
Expand Down
149 changes: 82 additions & 67 deletions tilebox-datasets/tilebox/datasets/buf/validate/validate_pb2.py
View file
Open in desktop

Large diffs are not rendered by default.

39 changes: 31 additions & 8 deletions tilebox-datasets/tilebox/datasets/buf/validate/validate_pb2.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
from google.protobuf import descriptor_pb2 as _descriptor_pb2
from google.protobuf import duration_pb2 as _duration_pb2
from google.protobuf import field_mask_pb2 as _field_mask_pb2
from google.protobuf import timestamp_pb2 as _timestamp_pb2
from google.protobuf.internal import containers as _containers
from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
Expand Down Expand Up @@ -48,12 +49,14 @@ class Rule(_message.Message):
def __init__(self, id: _Optional[str] = ..., message: _Optional[str] = ..., expression: _Optional[str] = ...) -> None: ...

class MessageRules(_message.Message):
__slots__ = ("cel", "oneof")
__slots__ = ("cel_expression", "cel", "oneof")
CEL_EXPRESSION_FIELD_NUMBER: _ClassVar[int]
CEL_FIELD_NUMBER: _ClassVar[int]
ONEOF_FIELD_NUMBER: _ClassVar[int]
cel_expression: _containers.RepeatedScalarFieldContainer[str]
cel: _containers.RepeatedCompositeFieldContainer[Rule]
oneof: _containers.RepeatedCompositeFieldContainer[MessageOneofRule]
def __init__(self, cel: _Optional[_Iterable[_Union[Rule, _Mapping]]] = ..., oneof: _Optional[_Iterable[_Union[MessageOneofRule, _Mapping]]] = ...) -> None: ...
def __init__(self, cel_expression: _Optional[_Iterable[str]] = ..., cel: _Optional[_Iterable[_Union[Rule, _Mapping]]] = ..., oneof: _Optional[_Iterable[_Union[MessageOneofRule, _Mapping]]] = ...) -> None: ...

class MessageOneofRule(_message.Message):
__slots__ = ("fields", "required")
Expand All @@ -70,7 +73,8 @@ class OneofRules(_message.Message):
def __init__(self, required: bool = ...) -> None: ...

class FieldRules(_message.Message):
__slots__ = ("cel", "required", "ignore", "float", "double", "int32", "int64", "uint32", "uint64", "sint32", "sint64", "fixed32", "fixed64", "sfixed32", "sfixed64", "bool", "string", "bytes", "enum", "repeated", "map", "any", "duration", "timestamp")
__slots__ = ("cel_expression", "cel", "required", "ignore", "float", "double", "int32", "int64", "uint32", "uint64", "sint32", "sint64", "fixed32", "fixed64", "sfixed32", "sfixed64", "bool", "string", "bytes", "enum", "repeated", "map", "any", "duration", "field_mask", "timestamp")
CEL_EXPRESSION_FIELD_NUMBER: _ClassVar[int]
CEL_FIELD_NUMBER: _ClassVar[int]
REQUIRED_FIELD_NUMBER: _ClassVar[int]
IGNORE_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -94,7 +98,9 @@ class FieldRules(_message.Message):
MAP_FIELD_NUMBER: _ClassVar[int]
ANY_FIELD_NUMBER: _ClassVar[int]
DURATION_FIELD_NUMBER: _ClassVar[int]
FIELD_MASK_FIELD_NUMBER: _ClassVar[int]
TIMESTAMP_FIELD_NUMBER: _ClassVar[int]
cel_expression: _containers.RepeatedScalarFieldContainer[str]
cel: _containers.RepeatedCompositeFieldContainer[Rule]
required: bool
ignore: Ignore
Expand All @@ -118,8 +124,9 @@ class FieldRules(_message.Message):
map: MapRules
any: AnyRules
duration: DurationRules
field_mask: FieldMaskRules
timestamp: TimestampRules
def __init__(self, cel: _Optional[_Iterable[_Union[Rule, _Mapping]]] = ..., required: bool = ..., ignore: _Optional[_Union[Ignore, str]] = ..., float: _Optional[_Union[FloatRules, _Mapping]] = ..., double: _Optional[_Union[DoubleRules, _Mapping]] = ..., int32: _Optional[_Union[Int32Rules, _Mapping]] = ..., int64: _Optional[_Union[Int64Rules, _Mapping]] = ..., uint32: _Optional[_Union[UInt32Rules, _Mapping]] = ..., uint64: _Optional[_Union[UInt64Rules, _Mapping]] = ..., sint32: _Optional[_Union[SInt32Rules, _Mapping]] = ..., sint64: _Optional[_Union[SInt64Rules, _Mapping]] = ..., fixed32: _Optional[_Union[Fixed32Rules, _Mapping]] = ..., fixed64: _Optional[_Union[Fixed64Rules, _Mapping]] = ..., sfixed32: _Optional[_Union[SFixed32Rules, _Mapping]] = ..., sfixed64: _Optional[_Union[SFixed64Rules, _Mapping]] = ..., bool: _Optional[_Union[BoolRules, _Mapping]] = ..., string: _Optional[_Union[StringRules, _Mapping]] = ..., bytes: _Optional[_Union[BytesRules, _Mapping]] = ..., enum: _Optional[_Union[EnumRules, _Mapping]] = ..., repeated: _Optional[_Union[RepeatedRules, _Mapping]] = ..., map: _Optional[_Union[MapRules, _Mapping]] = ..., any: _Optional[_Union[AnyRules, _Mapping]] = ..., duration: _Optional[_Union[DurationRules, _Mapping]] = ..., timestamp: _Optional[_Union[TimestampRules, _Mapping]] = ...) -> None: ...
def __init__(self, cel_expression: _Optional[_Iterable[str]] = ..., cel: _Optional[_Iterable[_Union[Rule, _Mapping]]] = ..., required: bool = ..., ignore: _Optional[_Union[Ignore, str]] = ..., float: _Optional[_Union[FloatRules, _Mapping]] = ..., double: _Optional[_Union[DoubleRules, _Mapping]] = ..., int32: _Optional[_Union[Int32Rules, _Mapping]] = ..., int64: _Optional[_Union[Int64Rules, _Mapping]] = ..., uint32: _Optional[_Union[UInt32Rules, _Mapping]] = ..., uint64: _Optional[_Union[UInt64Rules, _Mapping]] = ..., sint32: _Optional[_Union[SInt32Rules, _Mapping]] = ..., sint64: _Optional[_Union[SInt64Rules, _Mapping]] = ..., fixed32: _Optional[_Union[Fixed32Rules, _Mapping]] = ..., fixed64: _Optional[_Union[Fixed64Rules, _Mapping]] = ..., sfixed32: _Optional[_Union[SFixed32Rules, _Mapping]] = ..., sfixed64: _Optional[_Union[SFixed64Rules, _Mapping]] = ..., bool: _Optional[_Union[BoolRules, _Mapping]] = ..., string: _Optional[_Union[StringRules, _Mapping]] = ..., bytes: _Optional[_Union[BytesRules, _Mapping]] = ..., enum: _Optional[_Union[EnumRules, _Mapping]] = ..., repeated: _Optional[_Union[RepeatedRules, _Mapping]] = ..., map: _Optional[_Union[MapRules, _Mapping]] = ..., any: _Optional[_Union[AnyRules, _Mapping]] = ..., duration: _Optional[_Union[DurationRules, _Mapping]] = ..., field_mask: _Optional[_Union[FieldMaskRules, _Mapping]] = ..., timestamp: _Optional[_Union[TimestampRules, _Mapping]] = ...) -> None: ...

class PredefinedRules(_message.Message):
__slots__ = ("cel",)
Expand Down Expand Up @@ -381,7 +388,7 @@ class BoolRules(_message.Message):
def __init__(self, const: bool = ..., example: _Optional[_Iterable[bool]] = ...) -> None: ...

class StringRules(_message.Message):
__slots__ = ("const", "len", "min_len", "max_len", "len_bytes", "min_bytes", "max_bytes", "pattern", "prefix", "suffix", "contains", "not_contains", "not_in", "email", "hostname", "ip", "ipv4", "ipv6", "uri", "uri_ref", "address", "uuid", "tuuid", "ip_with_prefixlen", "ipv4_with_prefixlen", "ipv6_with_prefixlen", "ip_prefix", "ipv4_prefix", "ipv6_prefix", "host_and_port", "well_known_regex", "strict", "example")
__slots__ = ("const", "len", "min_len", "max_len", "len_bytes", "min_bytes", "max_bytes", "pattern", "prefix", "suffix", "contains", "not_contains", "not_in", "email", "hostname", "ip", "ipv4", "ipv6", "uri", "uri_ref", "address", "uuid", "tuuid", "ip_with_prefixlen", "ipv4_with_prefixlen", "ipv6_with_prefixlen", "ip_prefix", "ipv4_prefix", "ipv6_prefix", "host_and_port", "ulid", "well_known_regex", "strict", "example")
Extensions: _python_message._ExtensionDict
CONST_FIELD_NUMBER: _ClassVar[int]
LEN_FIELD_NUMBER: _ClassVar[int]
Expand Down Expand Up @@ -414,6 +421,7 @@ class StringRules(_message.Message):
IPV4_PREFIX_FIELD_NUMBER: _ClassVar[int]
IPV6_PREFIX_FIELD_NUMBER: _ClassVar[int]
HOST_AND_PORT_FIELD_NUMBER: _ClassVar[int]
ULID_FIELD_NUMBER: _ClassVar[int]
WELL_KNOWN_REGEX_FIELD_NUMBER: _ClassVar[int]
STRICT_FIELD_NUMBER: _ClassVar[int]
EXAMPLE_FIELD_NUMBER: _ClassVar[int]
Expand Down Expand Up @@ -447,13 +455,14 @@ class StringRules(_message.Message):
ipv4_prefix: bool
ipv6_prefix: bool
host_and_port: bool
ulid: bool
well_known_regex: KnownRegex
strict: bool
example: _containers.RepeatedScalarFieldContainer[str]
def __init__(self, const: _Optional[str] = ..., len: _Optional[int] = ..., min_len: _Optional[int] = ..., max_len: _Optional[int] = ..., len_bytes: _Optional[int] = ..., min_bytes: _Optional[int] = ..., max_bytes: _Optional[int] = ..., pattern: _Optional[str] = ..., prefix: _Optional[str] = ..., suffix: _Optional[str] = ..., contains: _Optional[str] = ..., not_contains: _Optional[str] = ..., not_in: _Optional[_Iterable[str]] = ..., email: bool = ..., hostname: bool = ..., ip: bool = ..., ipv4: bool = ..., ipv6: bool = ..., uri: bool = ..., uri_ref: bool = ..., address: bool = ..., uuid: bool = ..., tuuid: bool = ..., ip_with_prefixlen: bool = ..., ipv4_with_prefixlen: bool = ..., ipv6_with_prefixlen: bool = ..., ip_prefix: bool = ..., ipv4_prefix: bool = ..., ipv6_prefix: bool = ..., host_and_port: bool = ..., well_known_regex: _Optional[_Union[KnownRegex, str]] = ..., strict: bool = ..., example: _Optional[_Iterable[str]] = ..., **kwargs) -> None: ...
def __init__(self, const: _Optional[str] = ..., len: _Optional[int] = ..., min_len: _Optional[int] = ..., max_len: _Optional[int] = ..., len_bytes: _Optional[int] = ..., min_bytes: _Optional[int] = ..., max_bytes: _Optional[int] = ..., pattern: _Optional[str] = ..., prefix: _Optional[str] = ..., suffix: _Optional[str] = ..., contains: _Optional[str] = ..., not_contains: _Optional[str] = ..., not_in: _Optional[_Iterable[str]] = ..., email: bool = ..., hostname: bool = ..., ip: bool = ..., ipv4: bool = ..., ipv6: bool = ..., uri: bool = ..., uri_ref: bool = ..., address: bool = ..., uuid: bool = ..., tuuid: bool = ..., ip_with_prefixlen: bool = ..., ipv4_with_prefixlen: bool = ..., ipv6_with_prefixlen: bool = ..., ip_prefix: bool = ..., ipv4_prefix: bool = ..., ipv6_prefix: bool = ..., host_and_port: bool = ..., ulid: bool = ..., well_known_regex: _Optional[_Union[KnownRegex, str]] = ..., strict: bool = ..., example: _Optional[_Iterable[str]] = ..., **kwargs) -> None: ...

class BytesRules(_message.Message):
__slots__ = ("const", "len", "min_len", "max_len", "pattern", "prefix", "suffix", "contains", "not_in", "ip", "ipv4", "ipv6", "example")
__slots__ = ("const", "len", "min_len", "max_len", "pattern", "prefix", "suffix", "contains", "not_in", "ip", "ipv4", "ipv6", "uuid", "example")
Extensions: _python_message._ExtensionDict
CONST_FIELD_NUMBER: _ClassVar[int]
LEN_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -468,6 +477,7 @@ class BytesRules(_message.Message):
IP_FIELD_NUMBER: _ClassVar[int]
IPV4_FIELD_NUMBER: _ClassVar[int]
IPV6_FIELD_NUMBER: _ClassVar[int]
UUID_FIELD_NUMBER: _ClassVar[int]
EXAMPLE_FIELD_NUMBER: _ClassVar[int]
const: bytes
len: int
Expand All @@ -481,8 +491,9 @@ class BytesRules(_message.Message):
ip: bool
ipv4: bool
ipv6: bool
uuid: bool
example: _containers.RepeatedScalarFieldContainer[bytes]
def __init__(self, const: _Optional[bytes] = ..., len: _Optional[int] = ..., min_len: _Optional[int] = ..., max_len: _Optional[int] = ..., pattern: _Optional[str] = ..., prefix: _Optional[bytes] = ..., suffix: _Optional[bytes] = ..., contains: _Optional[bytes] = ..., not_in: _Optional[_Iterable[bytes]] = ..., ip: bool = ..., ipv4: bool = ..., ipv6: bool = ..., example: _Optional[_Iterable[bytes]] = ..., **kwargs) -> None: ...
def __init__(self, const: _Optional[bytes] = ..., len: _Optional[int] = ..., min_len: _Optional[int] = ..., max_len: _Optional[int] = ..., pattern: _Optional[str] = ..., prefix: _Optional[bytes] = ..., suffix: _Optional[bytes] = ..., contains: _Optional[bytes] = ..., not_in: _Optional[_Iterable[bytes]] = ..., ip: bool = ..., ipv4: bool = ..., ipv6: bool = ..., uuid: bool = ..., example: _Optional[_Iterable[bytes]] = ..., **kwargs) -> None: ...

class EnumRules(_message.Message):
__slots__ = ("const", "defined_only", "not_in", "example")
Expand Down Expand Up @@ -551,6 +562,18 @@ class DurationRules(_message.Message):
example: _containers.RepeatedCompositeFieldContainer[_duration_pb2.Duration]
def __init__(self, const: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ..., lt: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ..., lte: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ..., gt: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ..., gte: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ..., not_in: _Optional[_Iterable[_Union[_duration_pb2.Duration, _Mapping]]] = ..., example: _Optional[_Iterable[_Union[_duration_pb2.Duration, _Mapping]]] = ..., **kwargs) -> None: ...

class FieldMaskRules(_message.Message):
__slots__ = ("const", "not_in", "example")
Extensions: _python_message._ExtensionDict
CONST_FIELD_NUMBER: _ClassVar[int]
IN_FIELD_NUMBER: _ClassVar[int]
NOT_IN_FIELD_NUMBER: _ClassVar[int]
EXAMPLE_FIELD_NUMBER: _ClassVar[int]
const: _field_mask_pb2.FieldMask
not_in: _containers.RepeatedScalarFieldContainer[str]
example: _containers.RepeatedCompositeFieldContainer[_field_mask_pb2.FieldMask]
def __init__(self, const: _Optional[_Union[_field_mask_pb2.FieldMask, _Mapping]] = ..., not_in: _Optional[_Iterable[str]] = ..., example: _Optional[_Iterable[_Union[_field_mask_pb2.FieldMask, _Mapping]]] = ..., **kwargs) -> None: ...

class TimestampRules(_message.Message):
__slots__ = ("const", "lt", "lte", "lt_now", "gt", "gte", "gt_now", "within", "example")
Extensions: _python_message._ExtensionDict
Expand Down
10 changes: 7 additions & 3 deletions tilebox-datasets/tilebox/datasets/datasets/v1/collections_pb2.py
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading