Skip to content

Commit

Permalink
test fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
calgray committed Mar 11, 2022
1 parent e451f8e commit 1b2b9d0
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion daliuge-translator/dlg/dropmake/pg_generator.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,9 @@
import logging
import string
import time
from dlg.dropmake.lg import LG, GraphException
from dlg.dropmake.pgt import PGT
from dlg.dropmake.pgtp import MetisPGTP, MySarkarPGTP, MinNumPartsPGTP, PSOPGTP

logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -158,6 +161,8 @@ def partition(
topk = algo_params.get("topk", 30)
swarm_size = algo_params.get("swarm_size", 40)

max_dop = {"num_cpus": max_cpu, "mem_usage": max_mem}

if algo == ALGO_NONE:
pgt = PGT(pgt)

Expand All @@ -176,7 +181,6 @@ def partition(
)

elif algo == ALGO_MY_SARKAR:
max_dop = {"num_cpus": max_cpu, "mem_usage": max_mem}
pgt = MySarkarPGTP(
pgt, num_partitions, partition_label, max_dop, merge_parts=could_merge
)
Expand Down

0 comments on commit 1b2b9d0

Please sign in to comment.