in spotify_tensorflow/luigi/tensorflow_task.py [0:0]
def _mk_cloud_params(self):
params = []
if self.gcp_project:
params.append("--project=%s" % self.gcp_project)
params.extend(["jobs", "submit", "training", self._get_job_name()])
if self.region:
params.append("--region=%s" % self.region)
if self.ai_platform_conf:
params.append("--config=%s" % self.ai_platform_conf)
params.append("--job-dir=%s" % self.get_job_dir())
if self.blocking:
params.append("--stream-logs") # makes the execution "blocking"
if self.runtime_version:
params.append("--runtime-version=%s" % self.runtime_version)
if self.python_version:
params.append("--python-version=%s" % self.python_version)
if self.scale_tier:
params.append("--scale-tier=%s" % self.scale_tier)
return params