Skip to content

Commit

Permalink
black formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
guzzijones committed Jul 10, 2023
1 parent 46c7546 commit 3bff3e0
Show file tree
Hide file tree
Showing 5 changed files with 3 additions and 9 deletions.
1 change: 0 additions & 1 deletion orquesta/conducting.py
Original file line number Diff line number Diff line change
Expand Up @@ -370,7 +370,6 @@ def log_entry(
result=None,
data=None,
):

# Check entry type.
if entry_type not in ["info", "warn", "error"]:
raise exc.WorkflowLogEntryError('The log entry type "%s" is not valid.' % entry_type)
Expand Down
2 changes: 0 additions & 2 deletions orquesta/tests/hacking/import_aliases_rule.py
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,6 @@


def get_alias(logical_line):

parts = logical_line.split()

if (
Expand All @@ -68,7 +67,6 @@ def get_alias(logical_line):
and parts[1] != "__future__"
and not core.is_import_exception(parts[1])
):

# from path.to.module import module
if len(parts) == 4:
return ".".join([parts[1], parts[3]]), None
Expand Down
2 changes: 0 additions & 2 deletions orquesta/tests/unit/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,6 @@ def format_task_item(
items_count=None,
items_concurrency=None,
):

if not actions and items_count is None:
actions = [{"action": spec.action, "input": spec.input}]

Expand Down Expand Up @@ -285,7 +284,6 @@ def assert_task_items(
concurrency=None,
mock_ac_ex_results=None,
):

# Set up test cases.
tests = list(zip(mock_ac_ex_statuses, expected_task_statuses, expected_workflow_statuses))
tk_ex_result = [None] * len(items)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@


class WorkflowConductorDataFlowTest(test_base.WorkflowConductorTest):

wf_def_yaql = """
version: 1.0
Expand Down Expand Up @@ -157,14 +156,14 @@ def assert_data_flow(self, input_value):

def assert_unicode_data_flow(self, input_value):
inputs = {
u"a1": (
"a1": (
str_util.unicode(input_value, encoding_type="utf-8", force=True)
if six.PY2
else input_value
)
}

expected_output = {u"a5": inputs["a1"], u"b5": inputs["a1"]}
expected_output = {"a5": inputs["a1"], "b5": inputs["a1"]}

self._assert_data_flow(inputs, expected_output)

Expand Down
2 changes: 1 addition & 1 deletion orquesta/tests/unit/utils/test_strings.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ def test_unescape(self):
def test_unicode(self):
self.assertEqual(str_util.unicode(123), 123)
self.assertEqual(str_util.unicode("foobar"), "foobar")
self.assertEqual(str_util.unicode(u"fubar" if six.PY2 else str("fubar")), "fubar")
self.assertEqual(str_util.unicode("fubar" if six.PY2 else str("fubar")), "fubar")
self.assertEqual(str_util.unicode("鐵甲奇俠"), "鐵甲奇俠")
self.assertEqual(str_util.unicode("\xe9\x90\xb5\xe7\x94\xb2"), "\xe9\x90\xb5\xe7\x94\xb2")

Expand Down

0 comments on commit 3bff3e0

Please sign in to comment.