Inheritance diagram for bots.bot_utils.GSUtil:

Public Member Functions
	execute (self, gsutil_args)

	upload (self, local_path, remote_path, recursive=False, multithread=False)

	cat (self, remote_path)

	setGroupReadACL (self, remote_path, group)

	setContentType (self, remote_path, content_type)

	remove (self, remote_path, recursive=False)

Static Public Attributes
	GSUTIL_PATH = None

bool	USE_DART_REPO_VERSION = False

Protected Member Functions
	_layzCalculateGSUtilPath (self)

Detailed Description

Definition at line 56 of file bot_utils.py.

Member Function Documentation

◆ _layzCalculateGSUtilPath()

bots.bot_utils.GSUtil._layzCalculateGSUtilPath ( self )

protected

Definition at line 60 of file bot_utils.py.

    def _layzCalculateGSUtilPath(self):
        if not GSUtil.GSUTIL_PATH:
            dart_gsutil = os.path.join(DART_DIR, 'third_party', 'gsutil',
                                       'gsutil')
            if os.path.isfile(dart_gsutil):
                GSUtil.GSUTIL_PATH = dart_gsutil
            elif GSUtil.USE_DART_REPO_VERSION:
                raise Exception("Dart repository version of gsutil required, "
                                "but not found.")
            else:
                # We did not find gsutil, look in path
                possible_locations = list(os.environ['PATH'].split(os.pathsep))
                for directory in possible_locations:
                    location = os.path.join(directory, 'gsutil')
                    if os.path.isfile(location):
                        GSUtil.GSUTIL_PATH = location
                        break
            assert GSUtil.GSUTIL_PATH
 

◆ cat()

bots.bot_utils.GSUtil.cat	(	self,
		remote_path
	)

Definition at line 102 of file bot_utils.py.

    def cat(self, remote_path):
        assert remote_path.startswith('gs://')
 
        args = ['cat', remote_path]
        (stdout, _, _) = self.execute(args)
        return stdout
 

◆ execute()

bots.bot_utils.GSUtil.execute	(	self,
		gsutil_args
	)

Definition at line 79 of file bot_utils.py.

    def execute(self, gsutil_args):
        self._layzCalculateGSUtilPath()
 
        gsutil_command = [sys.executable, GSUtil.GSUTIL_PATH]
 
        return run(gsutil_command + gsutil_args)

◆ remove()

bots.bot_utils.GSUtil.remove	(	self,
		remote_path,
		recursive = `False`
	)

Definition at line 117 of file bot_utils.py.

    def remove(self, remote_path, recursive=False):
        assert remote_path.startswith('gs://')
 
        args = ['rm']
        if recursive:
            args += ['-R']
        args += [remote_path]
        self.execute(args)

◆ setContentType()

bots.bot_utils.GSUtil.setContentType	(	self,
		remote_path,
		content_type
	)

Definition at line 113 of file bot_utils.py.

    def setContentType(self, remote_path, content_type):
        args = ['setmeta', '-h', 'Content-Type:%s' % content_type, remote_path]
        self.execute(args)
 

◆ setGroupReadACL()

bots.bot_utils.GSUtil.setGroupReadACL	(	self,
		remote_path,
		group
	)

Definition at line 109 of file bot_utils.py.

    def setGroupReadACL(self, remote_path, group):
        args = ['acl', 'ch', '-g', '%s:R' % group, remote_path]
        self.execute(args)
 

◆ upload()

bots.bot_utils.GSUtil.upload	(	self,
		local_path,
		remote_path,
		recursive = `False`,
		multithread = `False`
	)

Definition at line 86 of file bot_utils.py.

               multithread=False):
        assert remote_path.startswith('gs://')
 
        if multithread:
            args = ['-m', 'cp']
        else:
            args = ['cp']
        if recursive:
            args += ['-R']
        args += [local_path, remote_path]
        self.execute(args)
 

Member Data Documentation

◆ GSUTIL_PATH

bots.bot_utils.GSUtil.GSUTIL_PATH = None

static

Definition at line 57 of file bot_utils.py.

◆ USE_DART_REPO_VERSION

bool bots.bot_utils.GSUtil.USE_DART_REPO_VERSION = False