in opmon/bigquery_client.py [0:0]
def execute(
self,
query: Union[str, List[str]],
destination_table: Optional[str] = None,
write_disposition: Optional[bigquery.job.WriteDisposition] = None,
clustering: Optional[List[str]] = None,
time_partitioning: Optional[str] = None,
partition_expiration_ms: Optional[int] = None,
dataset: Optional[str] = None,
join_keys: Optional[List[str]] = None,
annotations: Dict[str, Any] = {},