Airflow не может создать таблицу из пользовательской модели данных на initdb - PullRequest
Новая
       7

Airflow не может создать таблицу из пользовательской модели данных на initdb

1 голос
/ 05 июня 2019

Я разрабатываю собственный плагин воздушного потока, который должен отображать (пользовательскую) таблицу из базы данных метаданных 

class CampaignModel(Base, LoggingMixin):
    __tablename__ = "campaigns"

    id = Column(Integer, primary_key=True)
    campaign_name = Column(String(ID_LEN), unique=True)

class CampaignsView(ModelView):
    page_size = 50

v = CampaignsView(CampaignModel, settings.Session(), name="Campaigns")

class CampaignEditorPlugin(AirflowPlugin):
    name = "campaigns_plugin"
    ...
    admin_views = [v]
    ...

Воздушный поток запускается правильно и загружает плагин.Но он не будет создавать / регистрировать мою новую таблицу в CampaignModel на airflow initdb или airflow resetdb.

. Как правильно зарегистрировать таблицу, чтобы SQLAlchemy создавал ее на initdb

...