Skip to content

Create SqlToSlackOperator #24243

@eladkal

Description

@eladkal

Body

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.

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions