airflow/contrib/operators/mssql_to_gcs.py
def _upload_to_gcs(self, files_to_upload):
        """
        Upload all of the file splits (and optionally the schema .json file) to
        Google cloud storage.
        """
        hook = GoogleCloudStorageHook(
            google_cloud_storage_conn_id=self.google_cloud_storage_conn_id,
            delegate_to=self.delegate_to)
        for object_name, tmp_file_handle in files_to_upload.items():
            hook.upload(self.bucket, object_name, tmp_file_handle.name, 'application/json',
                        (self.gzip if object_name != self.schema_filename else False))
def _upload_to_gcs(self, files_to_upload):
        """
        Upload all of the file splits (and optionally the schema .json file) to
        Google cloud storage.
        """
        hook = GoogleCloudStorageHook(
            google_cloud_storage_conn_id=self.google_cloud_storage_conn_id,
            delegate_to=self.delegate_to)
        for object_name, tmp_file_handle in files_to_upload.items():
            hook.upload(self.bucket, object_name, tmp_file_handle.name, 'application/json',
                        (self.gzip if object_name != self.schema_filename else False))
Upload all of the file splits (and optionally the schema .json file) to
        Google cloud storage.