Worker execution runtime (#38)

* Update to latest protobuf messages

* Worker execution runtime

* refactor into task_executor api and runner facade

* Prepare release

Author: lukasbindreiter

CHANGELOG.md

@@ -7,7 +7,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
-## [0.52.0]
+## [0.53.0] - 2026-06-05
+
+### Added
+
+- `tilebox-workflows`: Added worker runtime mode for executing registered tasks over the worker RPC service, backed by a
+  shared task executor facade used by both worker and polling runners.
+
+## [0.52.0] - 2026-05-08
 
 ### Added
 
@@ -368,7 +375,8 @@ the first client that does not cache data (since it's already on the local file
 - Released under the [MIT](https://opensource.org/license/mit) license.
 - Released packages: `tilebox-datasets`, `tilebox-workflows`, `tilebox-storage`, `tilebox-grpc`
 
-[Unreleased]: https://github.com/tilebox/tilebox-python/compare/v0.52.0...HEAD
+[Unreleased]: https://github.com/tilebox/tilebox-python/compare/v0.53.0...HEAD
+[0.53.0]: https://github.com/tilebox/tilebox-python/compare/v0.52.0...v0.53.0
 [0.52.0]: https://github.com/tilebox/tilebox-python/compare/v0.51.0...v0.52.0
 [0.51.0]: https://github.com/tilebox/tilebox-python/compare/v0.50.1...v0.51.0
 [0.50.1]: https://github.com/tilebox/tilebox-python/compare/v0.50.0...v0.50.1

tilebox-datasets/tilebox/datasets/datasets/v1/collections_pb2_grpc.py

@@ -6,7 +6,7 @@
 from tilebox.datasets.datasets.v1 import core_pb2 as datasets_dot_v1_dot_core__pb2
 
 
-class CollectionServiceStub(object):
+class CollectionServiceStub:
     """CollectionService is the service definition for the Tilebox datasets service, which provides access to datasets
     """
 
@@ -38,7 +38,7 @@ def __init__(self, channel):
                 _registered_method=True)
 
 
-class CollectionServiceServicer(object):
+class CollectionServiceServicer:
     """CollectionService is the service definition for the Tilebox datasets service, which provides access to datasets
     """
 
@@ -97,7 +97,7 @@ def add_CollectionServiceServicer_to_server(servicer, server):
 
 
  # This class is part of an EXPERIMENTAL API.
-class CollectionService(object):
+class CollectionService:
     """CollectionService is the service definition for the Tilebox datasets service, which provides access to datasets
     """
 

tilebox-datasets/tilebox/datasets/datasets/v1/data_access_pb2_grpc.py

@@ -6,7 +6,7 @@
 from tilebox.datasets.datasets.v1 import data_access_pb2 as datasets_dot_v1_dot_data__access__pb2
 
 
-class DataAccessServiceStub(object):
+class DataAccessServiceStub:
     """DataAccessService provides data access and querying capabilities for Tilebox datasets.
     """
 
@@ -28,7 +28,7 @@ def __init__(self, channel):
                 _registered_method=True)
 
 
-class DataAccessServiceServicer(object):
+class DataAccessServiceServicer:
     """DataAccessService provides data access and querying capabilities for Tilebox datasets.
     """
 
@@ -67,7 +67,7 @@ def add_DataAccessServiceServicer_to_server(servicer, server):
 
 
  # This class is part of an EXPERIMENTAL API.
-class DataAccessService(object):
+class DataAccessService:
     """DataAccessService provides data access and querying capabilities for Tilebox datasets.
     """
 

tilebox-datasets/tilebox/datasets/datasets/v1/data_ingestion_pb2_grpc.py

@@ -5,7 +5,7 @@
 from tilebox.datasets.datasets.v1 import data_ingestion_pb2 as datasets_dot_v1_dot_data__ingestion__pb2
 
 
-class DataIngestionServiceStub(object):
+class DataIngestionServiceStub:
     """DataIngestionService provides data ingestion and deletion capabilities for Tilebox datasets.
     """
 
@@ -27,7 +27,7 @@ def __init__(self, channel):
                 _registered_method=True)
 
 
-class DataIngestionServiceServicer(object):
+class DataIngestionServiceServicer:
     """DataIngestionService provides data ingestion and deletion capabilities for Tilebox datasets.
     """
 
@@ -64,7 +64,7 @@ def add_DataIngestionServiceServicer_to_server(servicer, server):
 
 
  # This class is part of an EXPERIMENTAL API.
-class DataIngestionService(object):
+class DataIngestionService:
     """DataIngestionService provides data ingestion and deletion capabilities for Tilebox datasets.
     """
 

tilebox-datasets/tilebox/datasets/datasets/v1/datasets_pb2_grpc.py

@@ -6,7 +6,7 @@
 from tilebox.datasets.datasets.v1 import datasets_pb2 as datasets_dot_v1_dot_datasets__pb2
 
 
-class DatasetServiceStub(object):
+class DatasetServiceStub:
     """DatasetsService is the CRUD service for Tilebox datasets.
     """
 
@@ -43,7 +43,7 @@ def __init__(self, channel):
                 _registered_method=True)
 
 
-class DatasetServiceServicer(object):
+class DatasetServiceServicer:
     """DatasetsService is the CRUD service for Tilebox datasets.
     """
 
@@ -113,7 +113,7 @@ def add_DatasetServiceServicer_to_server(servicer, server):
 
 
  # This class is part of an EXPERIMENTAL API.
-class DatasetService(object):
+class DatasetService:
     """DatasetsService is the CRUD service for Tilebox datasets.
     """
 

tilebox-datasets/tilebox/datasets/tilebox/v1/query_pb2.py

@@ -1,13 +1,23 @@
 from tilebox.datasets.buf.validate import validate_pb2 as _validate_pb2
 from google.protobuf import timestamp_pb2 as _timestamp_pb2
 from tilebox.datasets.tilebox.v1 import id_pb2 as _id_pb2
+from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
 from collections.abc import Mapping as _Mapping
 from typing import ClassVar as _ClassVar, Optional as _Optional, Union as _Union
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
+class SortDirection(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
+    __slots__ = ()
+    SORT_DIRECTION_UNSPECIFIED: _ClassVar[SortDirection]
+    SORT_DIRECTION_ASCENDING: _ClassVar[SortDirection]
+    SORT_DIRECTION_DESCENDING: _ClassVar[SortDirection]
+SORT_DIRECTION_UNSPECIFIED: SortDirection
+SORT_DIRECTION_ASCENDING: SortDirection
+SORT_DIRECTION_DESCENDING: SortDirection
+
 class TimeInterval(_message.Message):
     __slots__ = ("start_time", "end_time", "start_exclusive", "end_inclusive")
     START_TIME_FIELD_NUMBER: _ClassVar[int]

tilebox-datasets/tilebox/datasets/tilebox/v1/query_pb2.pyi

@@ -10,7 +10,9 @@
 from tilebox.workflows.data import (
     Cluster,
 )
-from tilebox.workflows.workflows.v1.core_pb2 import Cluster as ClusterMessage
+from tilebox.workflows.workflows.v1.workflows_pb2 import (
+    Cluster as ClusterMessage,
+)
 from tilebox.workflows.workflows.v1.workflows_pb2 import (
     CreateClusterRequest,
     DeleteClusterRequest,

tilebox-workflows/tests/clusters/test_client.py

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:24ff20b8b66a30cf11e5998477066b500830280160eaa5dd1e1c5895ea920a47
-size 9032
+oid sha256:ede65a3f196290e2aee71cddc45f67c9e9b2c6eb1374bf6beb0b8406f1f4d8c4
+size 8923

tilebox-workflows/tests/runner/testdata/recordings/fibonacci_workflow.rpcs.bin

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:b8081ec6c43e20ee4ef13ff7ae89a24f695cd85e10c0346341d77a9fec5a285f
-size 6061
+oid sha256:54b3862b1e4c863f27e9f2e29958e3122ea8d197459fdb87e7b3d81ff0373f59
+size 5932