{"record":{"id":"99456f3a07b7b022","repo":"apache/beam","slug":"snowflake-transforms-moved-to-apache-beam-io-snowflake","errorCode":null,"errorMessage":"Snowflake transforms moved to apache_beam.io.snowflake","messagePattern":"Snowflake transforms moved to apache_beam\\.io\\.snowflake","errorType":"console","errorClass":null,"httpStatus":null,"severity":"warning","filePath":"sdks/python/apache_beam/io/external/snowflake.py","lineNumber":30,"sourceCode":"# distributed under the License is distributed on an \"AS IS\" BASIS,\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n# See the License for the specific language governing permissions and\n# limitations under the License.\n#\n\n# For backwards compatibility.\n\n# pytype: skip-file\n\nimport warnings\n\n# pylint: disable=unused-import\nfrom apache_beam.io.snowflake import CreateDisposition\nfrom apache_beam.io.snowflake import ReadFromSnowflake\nfrom apache_beam.io.snowflake import WriteDisposition\nfrom apache_beam.io.snowflake import WriteToSnowflake\n\nwarnings.warn(\n    \"Snowflake transforms moved to apache_beam.io.snowflake\",\n    DeprecationWarning)\n","sourceCodeStart":12,"sourceCodeEnd":33,"githubUrl":"https://github.com/apache/beam/blob/12126d8942aaf848030c478b4c6a28c6af861c66/sdks/python/apache_beam/io/external/snowflake.py#L12-L33","documentation":"Importing apache_beam.io.external.snowflake emits a DeprecationWarning because the Snowflake transforms (ReadFromSnowflake, WriteToSnowflake, CreateDisposition, WriteDisposition) were moved to apache_beam.io.snowflake. The old module is a re-export shim kept only for backward compatibility.","triggerScenarios":"Any execution of `from apache_beam.io.external.snowflake import ReadFromSnowflake` (or WriteToSnowflake/CreateDisposition/WriteDisposition) at import time.","commonSituations":"Legacy pipeline code referencing the old external io path; upgrading Beam or following outdated Snowflake connector docs.","solutions":["Change imports to `from apache_beam.io.snowflake import ReadFromSnowflake` etc.","Search the codebase for 'io.external.snowflake' and update all occurrences.","Re-run the pipeline to confirm no further deprecation warnings."],"exampleFix":"// before\nfrom apache_beam.io.external.snowflake import ReadFromSnowflake\n// after\nfrom apache_beam.io.snowflake import ReadFromSnowflake","handlingStrategy":"validation","validationCode":"import warnings\nwith warnings.catch_warnings(record=True) as w:\n    warnings.simplefilter('always')\n    import apache_beam.io.external.snowflake  # noqa\n    if any('moved to apache_beam.io.snowflake' in str(x.message) for x in w):\n        raise ImportError('Use apache_beam.io.snowflake instead')","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Import Snowflake transforms only from apache_beam.io.snowflake.","Run CI with -W error::DeprecationWarning.","Grep for 'io.external.snowflake' in code reviews."],"tags":["python","deprecation","apache-beam","snowflake"],"backgroundTag":"deprecated-api-usage","analyzedSha":"12126d8942aaf848030c478b4c6a28c6af861c66","analyzedAt":"2026-09-13T01:50:10.254Z","contentChangedAt":"2026-09-13T01:50:10.254Z","schemaVersion":2},"datasetVersion":"2026-09-20T03:17:13.778Z"}