diff --git a/mistral/tests/unit/db/v2/test_sqlalchemy_db_api.py b/mistral/tests/unit/db/v2/test_sqlalchemy_db_api.py
index 9692ea85e..21658b397 100644
--- a/mistral/tests/unit/db/v2/test_sqlalchemy_db_api.py
+++ b/mistral/tests/unit/db/v2/test_sqlalchemy_db_api.py
@@ -2975,7 +2975,7 @@ class ResourceMemberTest(SQLAlchemyTest):
             'workflow',
         )
 
-        self.assertTrue(2, len(fetched))
+        self.assertEqual(2, len(fetched))
 
     def test_get_resource_members_not_owner(self):
         created = db_api.create_resource_member(RESOURCE_MEMBERS[0])
@@ -2989,7 +2989,7 @@ class ResourceMemberTest(SQLAlchemyTest):
             'workflow',
         )
 
-        self.assertTrue(1, len(fetched))
+        self.assertEqual(1, len(fetched))
         self.assertEqual(created, fetched[0])
 
     def test_update_resource_member_by_member(self):
diff --git a/mistral/tests/unit/engine/test_direct_workflow.py b/mistral/tests/unit/engine/test_direct_workflow.py
index 0d8d9994d..6c7793aa2 100644
--- a/mistral/tests/unit/engine/test_direct_workflow.py
+++ b/mistral/tests/unit/engine/test_direct_workflow.py
@@ -90,7 +90,7 @@ class DirectWorkflowEngineTest(base.EngineTestCase):
         self.await_task_success(task1.id)
         self.await_task_success(task2.id)
 
-        self.assertTrue(wf_ex.state, states.ERROR)
+        self.assertEqual(wf_ex.state, states.SUCCESS)
 
     def test_condition_transition_not_triggering(self):
         wf_text = """---
@@ -131,7 +131,7 @@ class DirectWorkflowEngineTest(base.EngineTestCase):
 
         self.await_task_error(task1.id)
 
-        self.assertTrue(wf_ex.state, states.ERROR)
+        self.assertEqual(wf_ex.state, states.ERROR)
 
     def test_change_state_after_success(self):
         wf_text = """
@@ -223,7 +223,7 @@ class DirectWorkflowEngineTest(base.EngineTestCase):
         wf_ex = self._run_workflow(wf_text)
 
         self.assertIn('Invalid input', wf_ex.state_info)
-        self.assertTrue(wf_ex.state, states.ERROR)
+        self.assertEqual(wf_ex.state, states.ERROR)
 
     def test_wrong_first_task_input(self):
         wf_text = """
@@ -264,7 +264,7 @@ class DirectWorkflowEngineTest(base.EngineTestCase):
         # TODO(dzimine): Catch tasks caused error, and set them to ERROR:
         # TODO(dzimine): self.assertTrue(task_ex.state, states.ERROR)
 
-        self.assertTrue(wf_ex.state, states.ERROR)
+        self.assertEqual(wf_ex.state, states.ERROR)
         self.assertIn("Failed to find action", wf_ex.state_info)
 
     def test_wrong_action_first_task(self):