import logging

from airflow.models import BaseOperator
from airflow.plugins_manager import AirflowPlugin
from airflow.utils.decorators import apply_defaults

log = logging.getLogger(__name__)

class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)

    def execute(self, context):
        log.info("scheduling meeting... ")
        log.info('operator_param: %s', self.operator_param)

class MeetingSchedulerPlugin(AirflowPlugin):
    name = "meeting_scheduler_operator_plugin"
    operators = [MeetingSchedulerOperator]

5e4d1a0989918518ca0e24e612487e34178436e5
<mask token>


class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)
    <mask token>


class MeetingSchedulerPlugin(AirflowPlugin):
    name = 'meeting_scheduler_operator_plugin'
    operators = [MeetingSchedulerOperator]

<mask token>


class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)

    def execute(self, context):
        log.info('scheduling meeting... ')
        log.info('operator_param: %s', self.operator_param)


class MeetingSchedulerPlugin(AirflowPlugin):
    name = 'meeting_scheduler_operator_plugin'
    operators = [MeetingSchedulerOperator]

<mask token>
log = logging.getLogger(__name__)


class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)

    def execute(self, context):
        log.info('scheduling meeting... ')
        log.info('operator_param: %s', self.operator_param)


class MeetingSchedulerPlugin(AirflowPlugin):
    name = 'meeting_scheduler_operator_plugin'
    operators = [MeetingSchedulerOperator]

import logging
from airflow.models import BaseOperator
from airflow.plugins_manager import AirflowPlugin
from airflow.utils.decorators import apply_defaults
log = logging.getLogger(__name__)


class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)

    def execute(self, context):
        log.info('scheduling meeting... ')
        log.info('operator_param: %s', self.operator_param)


class MeetingSchedulerPlugin(AirflowPlugin):
    name = 'meeting_scheduler_operator_plugin'
    operators = [MeetingSchedulerOperator]

import logging

from airflow.models import BaseOperator
from airflow.plugins_manager import AirflowPlugin
from airflow.utils.decorators import apply_defaults

log = logging.getLogger(__name__)

class MeetingSchedulerOperator(BaseOperator):

    @apply_defaults
    def __init__(self, args_operator_param, *args, **kwargs):
        self.operator_param = args_operator_param
        super(MeetingSchedulerOperator, self).__init__(*args, **kwargs)

    def execute(self, context):
        log.info("scheduling meeting... ")
        log.info('operator_param: %s', self.operator_param)

class MeetingSchedulerPlugin(AirflowPlugin):
    name = "meeting_scheduler_operator_plugin"
    operators = [MeetingSchedulerOperator]
