Binoy Shah
08/24/2022, 3:41 PMsandy
08/24/2022, 6:02 PMStephen Bailey
08/26/2022, 10:58 AMkubernetes_job_op
to build custom schedules. one of the really hard parts here is managing the dependencies on the infra IMO. i've tried integrating a couple different ways and the kubernetes job way feels cleanestBinoy Shah
09/01/2022, 2:31 PMSoftware Defined Assets
the feature which is a strong selling point of Daster.Binoy Shah
09/01/2022, 2:32 PMBinoy Shah
09/01/2022, 2:32 PMBinoy Shah
09/01/2022, 2:34 PMStephen Bailey
09/01/2022, 6:17 PM@asset
def meltano_elt_salesforce():
# run meltano code
return {"some": "metadata"}
@asset
def meltano_elt_google_sheets():
# run meltano code
return {"some": "metadata"}
@asset
def dbt_build_project(meltano_elt_salesforce, meltano_elt_google_sheets):
# run dbt project code
return {"some": "metadata"}
that is, the higher-level "meltano elt" job for each source is one asset, as is the dbt build --select *
job. i think it's a bit hard to penetrate deeper into the job constructs (for example, mapping indvidual tables from each meltano job as assets)Stephen Bailey
09/01/2022, 6:18 PM# run meltnao code
is probably just subprocess.run("meltano elt salesforce target-snowflake")