Airflow plugin example

gistfile1.txt

from airflow.hooks.base_hook import BaseHook
from airflow.models import  BaseOperator
from airflow.executors.base_executor import BaseExecutor
from airflow import AirflowViewPlugin, AirflowMacroPlugin
from flask_admin import expose

class PluginHook(BaseHook):
    pass

class PluginOperator(BaseOperator):
    pass

class PluginExecutor(BaseExecutor):
    pass

class TestView(AirflowViewPlugin):
    @expose('/')
    def query(self):
        return self.render("anomaly/test.html", content="A VAR")

def return_success():
    return "Success!"

anomaly = AirflowMacroPlugin(namespace="anomaly")
anomaly.return_success = return_success

v = TestView(category="Something", name="Super")