fix: flake8

Signed-off-by: zjgemi <[email protected]>

Author: zjgemi

src/dflow/plugins/dispatcher.py

@@ -522,7 +522,7 @@ def render(self, template):
                 new_template.script += "    new_task_dict['backward_files']"\
                     ".append('./%s_' + str(i))\n" % path
             new_template.script += "    new_task_dict['backward_files']"\
-                ".append('log')\n" # work around no Bohrium result file
+                ".append('log')\n"  # work around no Bohrium result file
             new_template.script += "    with open('script' + str(i), 'w')"\
                 " as f:\n"
             new_template.script += "        f.write(new_script)\n"

src/dflow/step.py

@@ -587,8 +587,9 @@ def merge_output_artifact(art, parent, layer=0):
                         self.with_param = argo_range(ngroups)
                 else:
                     for name in sliced_input_artifact:
-                        self.inputs.parameters["dflow_%s_sub_path" %
-                                            name].value = "{{item.%s}}" % name
+                        self.inputs.parameters[
+                            "dflow_%s_sub_path" % name].value = \
+                                "{{item.%s}}" % name
                         v = self.inputs.artifacts[name].source
                         if isinstance(v, S3Artifact):
                             self.prepare_step.set_artifacts({
@@ -597,7 +598,8 @@ def merge_output_artifact(art, parent, layer=0):
                                 v.sub_path("{{item.%s}}" % name)
                         elif v is not None:
                             self.prepare_step.set_artifacts({name: v})
-                            self.inputs.artifacts[name].sp = "{{item.%s}}" % name
+                            self.inputs.artifacts[name].sp = "{{item.%s}}" % \
+                                name
                         if self.with_sequence is not None:
                             for par in self.inputs.parameters.values():
                                 if hasattr(par, "value") and isinstance(

src/dflow/util_ops.py

@@ -79,8 +79,8 @@ def __init__(self, template, image, command, image_pull_policy, key,
                         optional=True, sub_path=config["catalog_dir_name"])
                     self.outputs.parameters["dflow_slices_path"] = \
                         OutputParameter(
-                            value_from_path="%s/outputs/parameters/dflow_"\
-                                "slices_path" % self.tmp_root, type=dict)
+                            value_from_path="%s/outputs/parameters/dflow_"
+                            "slices_path" % self.tmp_root, type=dict)
 
         if self.sum_var is not None:
             name = self.sum_var.name