Skip to content

Commit 3bff3e0

Browse files
committed
black formatting
1 parent 46c7546 commit 3bff3e0

File tree

5 files changed

+3
-9
lines changed

5 files changed

+3
-9
lines changed

orquesta/conducting.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -370,7 +370,6 @@ def log_entry(
370370
result=None,
371371
data=None,
372372
):
373-
374373
# Check entry type.
375374
if entry_type not in ["info", "warn", "error"]:
376375
raise exc.WorkflowLogEntryError('The log entry type "%s" is not valid.' % entry_type)

orquesta/tests/hacking/import_aliases_rule.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,6 @@
5959

6060

6161
def get_alias(logical_line):
62-
6362
parts = logical_line.split()
6463

6564
if (
@@ -68,7 +67,6 @@ def get_alias(logical_line):
6867
and parts[1] != "__future__"
6968
and not core.is_import_exception(parts[1])
7069
):
71-
7270
# from path.to.module import module
7371
if len(parts) == 4:
7472
return ".".join([parts[1], parts[3]]), None

orquesta/tests/unit/base.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,6 @@ def format_task_item(
156156
items_count=None,
157157
items_concurrency=None,
158158
):
159-
160159
if not actions and items_count is None:
161160
actions = [{"action": spec.action, "input": spec.input}]
162161

@@ -285,7 +284,6 @@ def assert_task_items(
285284
concurrency=None,
286285
mock_ac_ex_results=None,
287286
):
288-
289287
# Set up test cases.
290288
tests = list(zip(mock_ac_ex_statuses, expected_task_statuses, expected_workflow_statuses))
291289
tk_ex_result = [None] * len(items)

orquesta/tests/unit/conducting/test_workflow_conductor_data_flow.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525

2626

2727
class WorkflowConductorDataFlowTest(test_base.WorkflowConductorTest):
28-
2928
wf_def_yaql = """
3029
version: 1.0
3130
@@ -157,14 +156,14 @@ def assert_data_flow(self, input_value):
157156

158157
def assert_unicode_data_flow(self, input_value):
159158
inputs = {
160-
u"a1": (
159+
"a1": (
161160
str_util.unicode(input_value, encoding_type="utf-8", force=True)
162161
if six.PY2
163162
else input_value
164163
)
165164
}
166165

167-
expected_output = {u"a5": inputs["a1"], u"b5": inputs["a1"]}
166+
expected_output = {"a5": inputs["a1"], "b5": inputs["a1"]}
168167

169168
self._assert_data_flow(inputs, expected_output)
170169

orquesta/tests/unit/utils/test_strings.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ def test_unescape(self):
2828
def test_unicode(self):
2929
self.assertEqual(str_util.unicode(123), 123)
3030
self.assertEqual(str_util.unicode("foobar"), "foobar")
31-
self.assertEqual(str_util.unicode(u"fubar" if six.PY2 else str("fubar")), "fubar")
31+
self.assertEqual(str_util.unicode("fubar" if six.PY2 else str("fubar")), "fubar")
3232
self.assertEqual(str_util.unicode("鐵甲奇俠"), "鐵甲奇俠")
3333
self.assertEqual(str_util.unicode("\xe9\x90\xb5\xe7\x94\xb2"), "\xe9\x90\xb5\xe7\x94\xb2")
3434

0 commit comments

Comments
 (0)