Skip to content
Merged
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#!/usr/bin/env python
#!/usr/bin/env python3

Check failure on line 1 in src/temporal/t.rast.aggregate.condition/t.rast.aggregate.condition.py

View workflow job for this annotation

GitHub Actions / Python Code Quality Checks (ubuntu-22.04)

[pylint] src/temporal/t.rast.aggregate.condition/t.rast.aggregate.condition.py E:232, 5: unsupported operand type(s) for | (unsupported-binary-operation) E:276,12: unsupported operand type(s) for | (unsupported-binary-operation) E:277,12: unsupported operand type(s) for | (unsupported-binary-operation) E:372,15: unsupported operand type(s) for | (unsupported-binary-operation) E:373,14: unsupported operand type(s) for | (unsupported-binary-operation) E:374,17: unsupported operand type(s) for | (unsupported-binary-operation) E:375,12: unsupported operand type(s) for | (unsupported-binary-operation) E:376,15: unsupported operand type(s) for | (unsupported-binary-operation) E:377,16: unsupported operand type(s) for | (unsupported-binary-operation) E:378,16: unsupported operand type(s) for | (unsupported-binary-operation) E:379,21: unsupported operand type(s) for | (unsupported-binary-operation) E:380,25: unsupported operand type(s) for | (unsupported-binary-operation) E:381,24: unsupported operand type(s) for | (unsupported-binary-operation) E:382,12: unsupported operand type(s) for | (unsupported-binary-operation) E:616,13: unsupported operand type(s) for | (unsupported-binary-operation) E:617,11: unsupported operand type(s) for | (unsupported-binary-operation) E:618,14: unsupported operand type(s) for | (unsupported-binary-operation) E:619,20: unsupported operand type(s) for | (unsupported-binary-operation) E:620,22: unsupported operand type(s) for | (unsupported-binary-operation) E:621,10: unsupported operand type(s) for | (unsupported-binary-operation)

"""MODULE: t.rast.aggregate.condition
AUTHOR(S): Stefan Blumentrath
Expand Down Expand Up @@ -433,6 +433,7 @@

# The module queue for parallel execution
process_queue = pymod.ParallelModuleQueue(nprocs)
aggregate_granules = 0
map_dict = {}
for raster_maps in map_list:
raster_map = tgis.RasterDataset(None)
Expand Down Expand Up @@ -588,19 +589,19 @@
output_condition_map=f"{output_name}_{condition_label}_{aggregate_condition}",
)
process_queue.put(pymod.MultiModule([condition_module, mc_module]))
aggregate_granules += 1

if not process_queue.get_num_run_procs() > 0:
gs.info(_("No enough maps found for aggregation"))
if not aggregate_granules > 0:
gs.info(_("Not enough maps found for aggregation."))
return []
gs.verbose(
_("Aggregating a total of %s time steps within %s granules")
% (
len(map_dict),
process_queue.get_num_run_procs(),
aggregate_granules,
),
)
# Add modules to process queue

process_queue.wait()

if connection_state_changed:
Expand Down
Loading