def METHOD_NAME(self, mock_create_engine: Any, mock_session_maker: Any) -> None:
    task = MySQLStalenessRemovalTask()
    job_config = ConfigFactory.from_dict({
        'job.identifier': 'mysql_remove_stale_data_job',
        f'{task.get_scope()}.{MySQLStalenessRemovalTask.CONN_STRING}': 'foobar',
        f'{task.get_scope()}.{MySQLStalenessRemovalTask.STALENESS_MAX_PCT}': 5,
        f'{task.get_scope()}.{MySQLStalenessRemovalTask.MS_TO_EXPIRE}': 86400000,
        MySQLCSVPublisher.JOB_PUBLISH_TAG: 'foo'
    })
    self.assertRaises(Exception, task.init, job_config)