Skip to content

Commit

Permalink
Add job_options related logging to AggregatorProcessing.evaluate
Browse files Browse the repository at this point in the history
  • Loading branch information
soxofaan committed May 3, 2024
1 parent 7795215 commit dff1124
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/openeo_aggregator/about.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
import sys
from typing import Optional

__version__ = "0.34.0a1"
__version__ = "0.34.1a1"


def log_version_info(logger: Optional[logging.Logger] = None):
Expand Down
2 changes: 2 additions & 0 deletions src/openeo_aggregator/backend.py
Original file line number Diff line number Diff line change
Expand Up @@ -590,10 +590,12 @@ def evaluate(self, process_graph: dict, env: EvalEnv = None):
if get_backend_config().job_options_update:
# Allow fine-tuning job options through config
job_options = get_backend_config().job_options_update(job_options=job_options, backend_id=backend_id)
_log.debug(f"AggregatorProcessing.evaluate: job_options_update produced {job_options=}")

if job_options:
# TODO: this (re)groups job options under "job_options" key, while original options might have been at root level.
# How should this be handled?
_log.info(f"AggregatorProcessing.evaluate: adding {job_options=} to sync processing request")
post_data["job_options"] = job_options

# TODO: inject job options here as well
Expand Down

0 comments on commit dff1124

Please sign in to comment.