<reponame>alercebroker/APF
from apf.core.step import GenericStep
import logging


class {{step_name}}(GenericStep):
    """{{step_name}} Description

    Parameters
    ----------
    consumer : GenericConsumer
        Description of parameter `consumer`.
    **step_args : type
        Other args passed to step (DB connections, API requests, etc.)

    """
    def __init__(self,consumer = None, config = None,level = logging.INFO,**step_args):
        super().__init__(consumer,config=config, level=level)

    def execute(self,message):
        ################################
        #   Here comes the Step Logic  #
        ################################

        pass

from apf.core.step import GenericStep
import logging


class {{step_name}}(GenericStep):
    """{{step_name}} Description

    Parameters
    ----------
    consumer : GenericConsumer
        Description of parameter `consumer`.
    **step_args : type
        Other args passed to step (DB connections, API requests, etc.)

    """
    def __init__(self,consumer = None, config = None,level = logging.INFO,**step_args):
        super().__init__(consumer,config=config, level=level)

    def execute(self,message):
        ################################
        #   Here comes the Step Logic  #
        ################################

        pass
{{step_name}} Description      Parameters     ----------     consumer : GenericConsumer         Description of parameter `consumer`.     **step_args : type         Other args passed to step (DB connections, API requests, etc.) ################################ #   Here comes the Step Logic  # ################################