Skip to content

Commit 51e7be0

Browse files
chriswmackeyChris Mackey
authored andcommitted
fix(glare): Update annual-glare for better parallelization
1 parent ec2f101 commit 51e7be0

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

lbt_recipes/imageless_annual_glare/flow/dependencies/imageless_annual_glare.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,7 @@ def output_artifacts(self):
309309
}]
310310

311311

312-
class _ImagelessAnnualGlare_bafe869fOrchestrator(luigi.WrapperTask):
312+
class _ImagelessAnnualGlare_67506d2bOrchestrator(luigi.WrapperTask):
313313
"""Runs all the tasks in this module."""
314314
# user input for this module
315315
_input_params = luigi.DictParameter()

lbt_recipes/imageless_annual_glare/flow/main.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import pathlib
1818
from queenbee_local import QueenbeeTask
1919
from queenbee_local import load_input_param as qb_load_input_param
20-
from .dependencies.imageless_annual_glare import _ImagelessAnnualGlare_bafe869fOrchestrator as ImagelessAnnualGlare_bafe869fWorkerbee
20+
from .dependencies.imageless_annual_glare import _ImagelessAnnualGlare_67506d2bOrchestrator as ImagelessAnnualGlare_67506d2bWorkerbee
2121

2222

2323
_default_inputs = { 'cpu_count': 50,
@@ -128,7 +128,7 @@ def map_dag_inputs(self):
128128
return inputs
129129

130130
def run(self):
131-
yield [ImagelessAnnualGlare_bafe869fWorkerbee(_input_params=self.map_dag_inputs)]
131+
yield [ImagelessAnnualGlare_67506d2bWorkerbee(_input_params=self.map_dag_inputs)]
132132
done_file = pathlib.Path(self.execution_folder, 'annual_imageless_glare.done')
133133
done_file.parent.mkdir(parents=True, exist_ok=True)
134134
done_file.write_text('done!')
@@ -809,7 +809,7 @@ def cpu_count(self):
809809

810810
@property
811811
def cpus_per_grid(self):
812-
return '3'
812+
return '1'
813813

814814
@property
815815
def min_sensor_count(self):
@@ -883,7 +883,7 @@ def output_parameters(self):
883883
return [{'name': 'sensor-grids', 'from': 'output_folder/_info.json', 'to': pathlib.Path(self.params_folder, 'output_folder/_info.json').resolve().as_posix()}]
884884

885885

886-
class _Main_bafe869fOrchestrator(luigi.WrapperTask):
886+
class _Main_67506d2bOrchestrator(luigi.WrapperTask):
887887
"""Runs all the tasks in this module."""
888888
# user input for this module
889889
_input_params = luigi.DictParameter()

lbt_recipes/imageless_annual_glare/run.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ class LetImagelessAnnualGlareFly(luigi.WrapperTask):
3939
_input_params = luigi.DictParameter()
4040

4141
def requires(self):
42-
yield [imageless_annual_glare_workerbee._Main_bafe869fOrchestrator(_input_params=self._input_params)]
42+
yield [imageless_annual_glare_workerbee._Main_67506d2bOrchestrator(_input_params=self._input_params)]
4343

4444

4545
def start(project_folder, user_values, workers):

0 commit comments

Comments
 (0)