Skip to content

Commit

Permalink
Issue #95 rename poc.py to openeo_aggregator.paritionedjobs.crossbackend
Browse files Browse the repository at this point in the history
  • Loading branch information
soxofaan committed Mar 13, 2023
1 parent cdc1807 commit ab2b886
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ class CrossBackendSplitter(AbstractJobSplitter):
Split a process graph, to be executed across multiple back-ends,
based on availability of collections
"""

def __init__(self, backend_for_collection: Callable[[str], str]):
# TODO: just handle this `backend_for_collection` callback with a regular method?
self.backend_for_collection = backend_for_collection
Expand Down Expand Up @@ -114,6 +115,7 @@ def namedtuples_to_dict(x):
return {k: namedtuples_to_dict(v) for k, v in x.items()}
else:
return x

print("Cross-backend split:")
pprint(namedtuples_to_dict(pjob), width=120)

Expand Down
Empty file.

0 comments on commit ab2b886

Please sign in to comment.