par_degerman
10/18/2023, 7:44 AMedgar_ramirez_mondragon
10/18/2023, 4:39 PMmeltano add --inherit-from ...
is probably a safer path. What does your meltano.yml
look like?par_degerman
10/18/2023, 6:53 PMversion: 1
default_environment: dev
project_id: us-cust
environments:
- name: dev
- name: prod
include_paths:
- stream-mappings.yml
- programs/*.yml
plugins:
extractors:
- name: source-db
inherit_from: tap-mysql
variant: transferwise
pip_url: pipelinewise-tap-mysql
config:
host: localhost
user: meltano
engine: mariadb
use_gtid: true
select:
- "*-Orders.*"
- "*-Payments.*"
- "!*-Payments.CreditCardNumber"
- "*-Customers.*"
- "!*-Customers.owner*"
- "!*-Customers.secondOwner*"
- "*-EventDataKey.*"
- "*-Export.*"
- "*-Note.*"
- "*-LogItem.*"
- "!*-LogItem.data"
metadata:
"*":
replication-method: LOG_BASED
And then I have this under programs/ohio.yml (I also have similar programs/florida.yml, and so forth):
plugins:
extractors:
- name: parma_oh
inherit_from: source-db
config:
filter_dbs: workflow_parma
- name: linndale_oh
inherit_from: source-db
config
filter_dbs: workflow_linndale
- name: gatesmills_oh
inherit_from: source-db
config:
filter_dbs: workflow_gatesmills
jobs:
- name: oh
tasks:
- parma_oh snowflake
- linndale_oh snowflake
- gatesmills_oh snowflake
schedules:
- name: ohio_daily
interval: "@daily"
job: oh
This setup has been working great for a few months, and recently I wanted to add a new city (Gates Mills, Ohio) so I went ahead and added it to the list of extractors in the ohio.yml file. However, the job fails when I run it in airflow complaining that it cannot find the extractor.edgar_ramirez_mondragon
10/18/2023, 7:08 PMpar_degerman
10/18/2023, 7:29 PMpar_degerman
10/18/2023, 8:40 PMedgar_ramirez_mondragon
10/18/2023, 9:07 PM