Skip to content

Instantly share code, notes, and snippets.

@saumalya75

saumalya75/airflow_arena:airflow_on_container:custom_plugin.py

Created May 29, 2020 19:26
Show Gist options
  • Save saumalya75/773b14d62edeb65564a4b95f129f53fc to your computer and use it in GitHub Desktop.
Save saumalya75/773b14d62edeb65564a4b95f129f53fc to your computer and use it in GitHub Desktop.
Download ZIP
Custom Plugin
Raw
airflow_arena:airflow_on_container:custom_plugin.py
from airflow.plugins_manager import AirflowPlugin
from sensors.custom_s3_sensor import CustomS3Sensor
from operators.custom_file_load_operator import CustomFileProcessingOperator
# Defining the plugin class
class CustomPlugin(AirflowPlugin):
name = "custom_plugin"
sensors = [CustomS3Sensor]
operators = [CustomFileProcessingOperator]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment