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.TARGET_TABLES}': ['table_metadata'],
        MySQLCSVPublisher.JOB_PUBLISH_TAG: 'foo'
    })
    task.init(job_config)
    filter_statement = task._get_stale_records_filter_condition(Table)
    self.assertTrue(str(filter_statement) == 'table_metadata.published_tag != :published_tag_1')
    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.TARGET_TABLES}': ['table_metadata'],
        f'{task.get_scope()}.{MySQLStalenessRemovalTask.MS_TO_EXPIRE}': 24 * 60 * 60 * 1000
    })
    task.init(job_config)
    filter_statement = task._get_stale_records_filter_condition(Table)
    self.assertTrue(str(filter_statement) == 'table_metadata.publisher_last_updated_epoch_ms < '
                                             ':publisher_last_updated_epoch_ms_1')