Skip to content

Commit

Permalink
Add send_area_to_processor to simple task
Browse files Browse the repository at this point in the history
  • Loading branch information
alexgleith committed Jan 3, 2024
1 parent 2088486 commit c7ed77b
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion dep_tools/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,10 @@ def run(self):
self.logger.info(f"Found {len(input_data.time)} timesteps to load")

self.logger.info("Preparing to process data")
output_data = self.processor.process(input_data)
processor_kwargs = {}
if self.processor.send_area_to_processor:
processor_kwargs["area"] = self.area
output_data = self.processor.process(input_data, **processor_kwargs)
self.logger.info(f"Processed data will have a result of shape: {[output_data.dims[d] for d in ['x', 'y']]}")

self.logger.info("Processing and writing data...")
Expand Down

0 comments on commit c7ed77b

Please sign in to comment.