def execute(self, context):
    cursor = self.query()
    files_to_upload = self._write_local_data_files(cursor)
    if self.schema_filename:
        files_to_upload.append(self._write_local_schema_file(cursor))
    for tmp_file in files_to_upload:
        tmp_file['file_handle'].flush()
    self._upload_to_gcs(files_to_upload)
    for tmp_file in files_to_upload:
        tmp_file['file_handle'].close()
def execute(self, context):
    cursor = self.query()
    files_to_upload = self._write_local_data_files(cursor)
    if self.schema_filename:
        files_to_upload.append(self._write_local_schema_file(cursor))
    for tmp_file in files_to_upload:
        tmp_file['file_handle'].flush()
    self._upload_to_gcs(files_to_upload)
    for tmp_file in files_to_upload:
        tmp_file['file_handle'].close()