You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently we have SnowflakeToSlackOperator & PrestoToSlackOperator.
This task is to create a generic SqlToSlackOperator to be compatible with all hooks that has get_pandas_df function.
The new operator should be in providers/slack/transfers/sql_to_slack.py, once completed we can also deprecate SnowflakeToSlackOperator & PrestoToSlackOperator.
A good resource for reference can be SqlToS3Operator which the first part of the operator (running query and creating dataframe should be identical), the 2nd part of creating the slack message should be very similar to what the current operators do.
Committer
I acknowledge that I am a maintainer/committer of the Apache Airflow project.
The text was updated successfully, but these errors were encountered:
Body
Currently we have
SnowflakeToSlackOperator
&PrestoToSlackOperator
.This task is to create a generic
SqlToSlackOperator
to be compatible with all hooks that hasget_pandas_df
function.The new operator should be in
providers/slack/transfers/sql_to_slack.py
, once completed we can also deprecateSnowflakeToSlackOperator
&PrestoToSlackOperator
.A good resource for reference can be
SqlToS3Operator
which the first part of the operator (running query and creating dataframe should be identical), the 2nd part of creating the slack message should be very similar to what the current operators do.Committer
The text was updated successfully, but these errors were encountered: