def METHOD_NAME(self):
    self.workflow.do_engine_steps()
    self.assertIn("a", self.workflow.data)
    self.assertIn("b", self.workflow.data)
    self.assertIn("c", self.workflow.data)
    self.assertIn("d", self.workflow.data)
    task_data_len = self._get_task_data_len()
    d_uniques = set(self.workflow.data["d"])
    d_len = len(self.workflow.data["d"])
    self.assertGreater(task_data_len, 15000)
    self.assertEqual(d_len, 512*3)
    self.assertEqual(d_uniques, {"a", "b", "c"})