Przeglądaj źródła

clean C405 rule for codestyle

ooooo 1 rok temu
rodzic
commit
1c56910711

+ 1 - 1
taipy/core/_orchestrator/_orchestrator.py

@@ -255,7 +255,7 @@ class _Orchestrator(_AbstractOrchestrator):
             cls.__logger.info(f"{job.id} has already failed and cannot be canceled.")
         else:
             with cls.lock:
-                to_cancel_or_abandon_jobs = set([job])
+                to_cancel_or_abandon_jobs = {job}
                 to_cancel_or_abandon_jobs.update(cls.__find_subsequent_jobs(job.submit_id, set(job.task.output.keys())))
                 cls.__remove_blocked_jobs(to_cancel_or_abandon_jobs)
                 cls.__remove_jobs_to_run(to_cancel_or_abandon_jobs)

+ 1 - 1
taipy/core/notification/event.py

@@ -49,7 +49,7 @@ class EventEntityType(_ReprEnum):
     SUBMISSION = 7
 
 
-_NO_ATTRIBUTE_NAME_OPERATIONS = set([EventOperation.CREATION, EventOperation.DELETION, EventOperation.SUBMISSION])
+_NO_ATTRIBUTE_NAME_OPERATIONS = {EventOperation.CREATION, EventOperation.DELETION, EventOperation.SUBMISSION}
 _UNSUBMITTABLE_ENTITY_TYPES = (
     EventEntityType.CYCLE,
     EventEntityType.DATA_NODE,

+ 1 - 1
tests/core/config/test_scenario_config.py

@@ -150,7 +150,7 @@ def test_scenario_getitem():
 
     assert scenario.tasks == [task_config_1, task_config_2]
     assert scenario.additional_data_node_configs == [dn_config_4]
-    assert set(scenario.data_nodes) == set([dn_config_4, dn_config_1, dn_config_2, dn_config_3])
+    assert set(scenario.data_nodes) == {dn_config_4, dn_config_1, dn_config_2, dn_config_3}
 
     assert Config.scenarios[scenario_id].properties == scenario.properties
 

+ 1 - 1
tests/core/conftest.py

@@ -280,7 +280,7 @@ def sequence():
         [],
         SequenceId("sequence_id"),
         owner_id="owner_id",
-        parent_ids=set(["parent_id_1", "parent_id_2"]),
+        parent_ids={"parent_id_1", "parent_id_2"},
         version="random_version_number",
     )
 

+ 1 - 1
tests/core/scenario/test_scenario_manager.py

@@ -936,7 +936,7 @@ def test_is_submittable():
 
     dn_config = Config.configure_in_memory_data_node("dn", 10)
     task_config = Config.configure_task("task", print, [dn_config])
-    scenario_config = Config.configure_scenario("sc", set([task_config]), set(), Frequency.DAILY)
+    scenario_config = Config.configure_scenario("sc", {task_config}, set(), Frequency.DAILY)
     scenario = _ScenarioManager._create(scenario_config)
 
     assert len(_ScenarioManager._get_all()) == 1

+ 4 - 4
tests/core/sequence/test_sequence_manager.py

@@ -74,7 +74,7 @@ def __init():
     input_dn = InMemoryDataNode("foo", Scope.SCENARIO)
     output_dn = InMemoryDataNode("foo", Scope.SCENARIO)
     task = Task("task", {}, print, [input_dn], [output_dn], TaskId("task_id"))
-    scenario = Scenario("scenario", set([task]), {}, set())
+    scenario = Scenario("scenario", {task}, {}, set())
     _ScenarioManager._set(scenario)
     return scenario, task
 
@@ -122,7 +122,7 @@ def test_set_and_get():
 
     # We save the first sequence again. We expect an exception and nothing to change
     with pytest.raises(SequenceAlreadyExists):
-       scenario.add_sequence(sequence_name_1, [])
+        scenario.add_sequence(sequence_name_1, [])
     sequence_1 = scenario.sequences[sequence_name_1]
     assert _SequenceManager._get(sequence_id_1).id == sequence_1.id
     assert len(_SequenceManager._get(sequence_id_1).tasks) == 0
@@ -191,7 +191,7 @@ def test_get_all_on_multiple_versions_environment():
 def test_is_submittable():
     dn = InMemoryDataNode("dn", Scope.SCENARIO, properties={"default_data": 10})
     task = Task("task", {}, print, [dn])
-    scenario = Scenario("scenario", set([task]), {}, set())
+    scenario = Scenario("scenario", {task}, {}, set())
     _ScenarioManager._set(scenario)
 
     scenario.add_sequences({"sequence": [task]})
@@ -724,7 +724,7 @@ def test_export(tmpdir_factory):
     task = Task("task", {}, print, id=TaskId("task_id"))
     scenario = Scenario(
         "scenario",
-        set([task]),
+        {task},
         {},
         set(),
         version="1.0",

+ 1 - 1
tests/core/task/test_task_manager.py

@@ -82,7 +82,7 @@ def test_assign_task_as_parent_of_datanode():
 
     dns = {dn.config_id: dn for dn in _DataManager._get_all()}
     assert dns["dn_1"].parent_ids == {tasks[0].id}
-    assert dns["dn_2"].parent_ids == set([tasks[0].id, tasks[1].id])
+    assert dns["dn_2"].parent_ids == {tasks[0].id, tasks[1].id}
     assert dns["dn_3"].parent_ids == {tasks[1].id}