gfw.common.beam.pipeline.hooks.delete_events_hook#

delete_events_hook(table_config, start_date, end_date=None, mock=False)[source]#

Returns a hook function to delete events from a BigQuery table.

Parameters:

  • table_config (TableConfig) – TableConfig object containing table detailsand delete query.

  • start_date (date) – Date after which events should be deleted.

  • end_date (date | None) – Date up to which events should be deleted (exclusive).

  • mock (bool) – If True, uses a mocked BQ client instead of performing real operations.

Returns:

A callable hook that accepts a Pipeline instance and deletes events.

Return type:

Callable[[Pipeline], None]