dwallace0723 / dbt-cloud-plugin

DBT Cloud Plugin for Airflow

dbt-cloud-plugin

DBT Cloud Plugin for Airflow

dbt-cloud-plugin's Issues

ERROR - No module named 'dbt_cloud_plugin.sensors.dbt_cloud_run_sensor'

Hello @dwallace0723 thanks a lot for the plugin.

When I imported the plugin and I retarted the Airflow Scheduler/Webserver, I got:

"ERROR - No module named 'dbt_cloud_plugin.sensors.dbt_cloud_run_sensor'"

The issue was in the name of the file for sensor plugin into "init.py" file. Line 4.

from dbt_cloud_plugin.sensors.dbt_cloud_run_sensor import DbtCloudRunSensor

And the name of the file is: github.com/dwallace0723/dbt-cloud-plugin/blob/master/dbt_cloud_plugin/sensors/dbt_cloud_job_sensor.py

So, I had to change this line to:

dbt_cloud_run_sensor to dbt_cloud_job_sensor

from dbt_cloud_plugin.sensors.dbt_cloud_job_sensor import DbtCloudRunSensor

After this fix it worked.

Maybe this change could be add to the code. It would be more beginner-friendly

Make data argument mandatory in run_job method

Hey, @dwallace0723 thanks very much for the plugin 🙏 .

I guess it serves me well for not reading the API documentation thoroughly before trying to use the API

I got a little hung up by this when I forgot to pass a trigger value to the run_job method.

db = DbtCloud(id,token)
db.run_job('job_name')
{"detail":"There was a server error. Please contact support at [email protected]."}'

This is the error message the API gives back

db.run_job('job_name',data={'cause':'trigger'})

^ This works

Do you think we could make the data argument mandatory - It would be more beginner-friendly