Skip to content

Commit

Permalink
fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
leo-schick committed Feb 24, 2023
1 parent 6fa24ba commit 9dea418
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions mara_pipelines/logging/node_cost.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
from .. import pipelines


def node_durations_and_run_times(node: pipelines.Node) -> Dict[tuple, [float, float]]:
def node_durations_and_run_times(node: pipelines.Node) -> Dict[tuple, object]: # object = [float, float]
"""
Returns for children of `node` the average duration and run time (sum of average duration of all leaf nodes)
Expand Down Expand Up @@ -44,7 +44,7 @@ def node_durations_and_run_times(node: pipelines.Node) -> Dict[tuple, [float, fl
return {tuple(row[0]): row[1:] for row in cursor.fetchall()}


def compute_cost(node: pipelines.Node, node_durations_and_run_times: Dict[tuple, [float, float]]) -> float:
def compute_cost(node: pipelines.Node, node_durations_and_run_times: Dict[tuple, object]) -> float: # object = [float, float]
"""
Computes the cost of a node as maximum cumulative run time of a node and all its downstreams.
Stores the result in `node` and also returns it
Expand Down

0 comments on commit 9dea418

Please sign in to comment.