def METHOD_NAME(self):
    input_to_service = '{"test_key": "test_value"}'
    self.cwe_event_source.Input = input_to_service
    resources = self.cwe_event_source.to_cloudformation(resource=self.state_machine)
    self.assertEqual(len(resources), 2)
    event_rule = resources[0]
    self.assertEqual(event_rule.Targets[0]["Input"], input_to_service)