async def METHOD_NAME(loop, application: Flask = None):  # pylint: disable=redefined-outer-name
    """Run the methods for applying future effective filings."""
    if application is None:
        application = create_app()
    queue_service = ServiceWorker(
        loop=loop,
        nats_connection_options=default_nats_options,
        stan_connection_options=default_stan_options,
        config=config.get_named_config('production')
    )
    await queue_service.connect()
    with application.app_context():
        try:
            filings = get_filings(app=application)
            if not filings:
                application.logger.debug('No PAID filings found to apply.')
            for filing in filings:
                filing_id = filing['filing']['header']['filingId']
                effective_date = filing['filing']['header']['effectiveDate']
                # NB: effective_date and now are both UTC
                now = datetime.utcnow().replace(tzinfo=timezone.utc)
                valid = effective_date and parse(effective_date) <= now
                if valid:
                    msg = {'filing': {'id': filing_id}}
                    await queue_service.publish(subject, msg)
                    application.logger.debug(f'Successfully put filing {filing_id} on the queue.')
        except Exception as err:  # pylint: disable=broad-except
            application.logger.error(err)