Update protobuf api

Author: lukasbindreiter

CHANGELOG.md

@@ -7,6 +7,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.59.0] - 2026-08-18
+
 ### Added
 
 - `tilebox-workflows`: Added support for asynchronous task `execute()` methods, allowing tasks to await async APIs
@@ -25,6 +27,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   - Tilebox Datasets `TimeInterval`, `IDInterval`, and `SpatialFilter`.
   - Raster windows from Rasterio and async-geotiff when the corresponding optional library is installed.
 
+### Changed
+
+- `tilebox-workflows`: job responses no longer include task summaries.
+- `tilebox-workflows`: Use `GetJob` for live notebook progress updates
+
 ### Fixed
 
 - `tilebox-workflows`: Propagate the task ID to all OpenTelemetry sub-spans created during task execution.
@@ -464,7 +471,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.58.0...HEAD
+[Unreleased]: https://github.com/tilebox/tilebox-python/compare/v0.59.0...HEAD
+[0.59.0]: https://github.com/tilebox/tilebox-python/compare/v0.58.0...v0.59.0 
 [0.58.0]: https://github.com/tilebox/tilebox-python/compare/v0.57.0...v0.58.0 
 [0.57.0]: https://github.com/tilebox/tilebox-python/compare/v0.56.0...v0.57.0
 [0.56.0]: https://github.com/tilebox/tilebox-python/compare/v0.55.1...v0.56.0

tilebox-workflows/tilebox/workflows/jobs/service.py

@@ -17,7 +17,6 @@
 from tilebox.workflows.workflows.v1.diagram_pb2 import Diagram, RenderOptions
 from tilebox.workflows.workflows.v1.job_pb2 import (
     CancelJobRequest,
-    GetJobProgressRequest,
     GetJobRequest,
     QueryJobsRequest,
     RetryJobRequest,
@@ -46,16 +45,12 @@ def submit(self, job_name: str, trace_parent: str, tasks: TaskSubmissions) -> Jo
             job_name=job_name,
             trace_parent=trace_parent,
         )
-        return RichDisplayJob.from_message(self.service.SubmitJob(request), _widget=JobWidget(self.get_progress))
+        return RichDisplayJob.from_message(self.service.SubmitJob(request), _widget=JobWidget(self.get_by_id))
 
     def get_by_id(self, job_id: UUID) -> Job:
         request = GetJobRequest(job_id=uuid_to_uuid_message(job_id))
         response: JobMessage = self.service.GetJob(request)
-        return RichDisplayJob.from_message(response, _widget=JobWidget(self.get_progress))
-
-    def get_progress(self, job_id: UUID) -> Job:
-        request = GetJobProgressRequest(job_id=uuid_to_uuid_message(job_id))
-        return Job.from_message(self.service.GetJobProgress(request))
+        return RichDisplayJob.from_message(response, _widget=JobWidget(self.get_by_id))
 
     def retry(self, job_id: UUID) -> int:
         request = RetryJobRequest(job_id=uuid_to_uuid_message(job_id))
@@ -82,5 +77,5 @@ def query(self, filters: QueryFilters, page: Pagination | None = None) -> QueryJ
         response: QueryJobsResponseMessage = self.service.QueryJobs(request)
 
         return QueryJobsResponse.from_message(
-            response, job_factory=lambda job: RichDisplayJob.from_message(job, _widget=JobWidget(self.get_progress))
+            response, job_factory=lambda job: RichDisplayJob.from_message(job, _widget=JobWidget(self.get_by_id))
         )

tilebox-workflows/tilebox/workflows/runner/executor.py

@@ -4,7 +4,6 @@
 import inspect
 import json
 import logging
-from base64 import b64encode
 from collections.abc import Awaitable, Callable, Iterator, MutableMapping, Sequence
 from concurrent.futures import ThreadPoolExecutor
 from contextlib import AbstractContextManager, contextmanager
@@ -87,7 +86,6 @@ def execute_task(
 
                 try:
                     task_instance = task_class._deserialize(task.input, self.runner_context)  # noqa: SLF001
-                    _set_task_input_span_attribute(span, task.input)
                     with wrap_execute_context_manager(task, context):
                         _execute(task_instance, context)
 
@@ -280,16 +278,6 @@ def _finalize_mutable_progress_trackers(
     return [ProgressIndicator(label, bar._total, bar._done) for label, bar in progress_bars.items()]  # noqa: SLF001
 
 
-def _set_task_input_span_attribute(span: object, task_input: bytes | None) -> None:
-    task_input_span_attr = ""
-    if task_input is not None:
-        try:
-            task_input_span_attr = task_input.decode("utf-8")
-        except UnicodeDecodeError:
-            task_input_span_attr = b64encode(task_input).decode("ascii")
-    span.set_attribute("input", task_input_span_attr)  # ty: ignore[unresolved-attribute]
-
-
 def _execute(task: TaskInstance, context: ExecutionContext) -> None:
     result = task.execute(context)
     if inspect.isawaitable(result):