{"record":{"id":"5260a2a1e3a5b2a1","repo":"apache/beam","slug":"native-sources-no-longer-implemented-falling-back-to","errorCode":null,"errorMessage":"Native sources no longer implemented; falling back to standard Beam source.","messagePattern":"Native sources no longer implemented; falling back to standard Beam source\\.","errorType":"console","errorClass":null,"httpStatus":null,"severity":"warning","filePath":"sdks/python/apache_beam/io/gcp/bigquery.py","lineNumber":664,"sourceCode":"\n# -----------------------------------------------------------------------------\n# BigQuerySource, BigQuerySink.\n\n\n@deprecated(since='2.25.0', current=\"ReadFromBigQuery\")\ndef BigQuerySource(\n    table=None,\n    dataset=None,\n    project=None,\n    query=None,\n    validate=False,\n    coder=None,\n    use_standard_sql=False,\n    flatten_results=True,\n    kms_key=None,\n    use_dataflow_native_source=False):\n  if use_dataflow_native_source:\n    warnings.warn(\n        \"Native sources no longer implemented; \"\n        \"falling back to standard Beam source.\")\n  return ReadFromBigQuery(\n      table=table,\n      dataset=dataset,\n      project=project,\n      query=query,\n      validate=validate,\n      coder=coder,\n      use_standard_sql=use_standard_sql,\n      flatten_results=flatten_results,\n      use_json_exports=True,\n      kms_key=kms_key)\n\n\n@deprecated(since='2.25.0', current=\"ReadFromBigQuery\")\ndef _BigQuerySource(*args, **kwargs):\n  \"\"\"A source based on a BigQuery table.\"\"\"","sourceCodeStart":646,"sourceCodeEnd":682,"githubUrl":"https://github.com/apache/beam/blob/12126d8942aaf848030c478b4c6a28c6af861c66/sdks/python/apache_beam/io/gcp/bigquery.py#L646-L682","documentation":"The legacy BigQuerySource helper function warns that Dataflow native BigQuery sources are no longer implemented and the pipeline falls back to the standard Beam source. It still returns a working ReadFromBigQuery transform, but `use_dataflow_native_source=True` has no effect.","triggerScenarios":"Calling `BigQuerySource(..., use_dataflow_native_source=True)` in apache_beam.io.gcp.bigquery (e.g. tests or old pipeline code).","commonSituations":"Migrating old Dataflow pipelines that relied on the native BQ source; test code instantiating the legacy source helper directly.","solutions":["Remove `use_dataflow_native_source=True` and use `ReadFromBigQuery` directly.","Update test code to target ReadFromBigQuery instead of the legacy helper.","Suppress the warning only if the fallback is accepted: `warnings.filterwarnings('ignore', message='Native sources no longer implemented')`."],"exampleFix":"// before\nsrc = BigQuerySource(table='t', use_dataflow_native_source=True)\n// after\nsrc = ReadFromBigQuery(table='t')","handlingStrategy":"validation","validationCode":"if kwargs.get('use_dataflow_native_source'):\n    raise ValueError('use_dataflow_native_source is ignored; use ReadFromBigQuery')","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Drop use_dataflow_native_source from pipeline construction code.","Standardize on ReadFromBigQuery for all BigQuery reads.","Run tests with -W error to surface this warning early."],"tags":["python","deprecation","apache-beam","bigquery"],"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"}