Skip to content

Query Athena in the Pipeline Object with Parameters #3489

@idanmoradarthas

Description

@idanmoradarthas

Describe the feature you'd like
As of today, using the AthenaDatasetDefinition object as an input in ProcessingInput, require a string SQL query. If the query is dependent on pipeline parameters (such as dates) you are unable to use it. Placing the parameters in string converts them automatically into their default value in the upsert stage, and thus when executing the pipeline with different parameters creates the wrong query.

How would this feature be used? Please describe.
The query_string attribute in the AthenaDatasetDefinition object will be able to calculate pipeline parameters, as output_s3_uri is able with the object sagemaker.workflow.functions.Join

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions