Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1606 Add additional fields to Batch job status endpoint

Browse Source
This commit is contained in:
Tom Grace 2018-05-02 13:31:35 +01:00
parent cb364eedc6
commit 94fa94c2df
No known key found for this signature in database
GPG Key ID: 02EE9B18CAC00997
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
moto/batch/models.py
View File

@ -295,6 +295,14 @@ class Job(threading.Thread, BaseModel):
} }
if self.job_stopped: if self.job_stopped:
result['stoppedAt'] = datetime2int(self.job_stopped_at) result['stoppedAt'] = datetime2int(self.job_stopped_at)
result['container'] = {}
result['container']['command'] = ['/bin/sh -c "for a in `seq 1 10`; do echo Hello World; sleep 1; done"']
result['container']['privileged'] = False
result['container']['readonlyRootFilesystem'] = False
result['container']['ulimits'] = {}
result['container']['vcpus'] = 1
result['container']['volumes'] = ''
result['container']['logStreamName'] = self.log_stream_name
if self.job_stopped_reason is not None: if self.job_stopped_reason is not None:
result['statusReason'] = self.job_stopped_reason result['statusReason'] = self.job_stopped_reason
return result return result
@ -378,6 +386,7 @@ class Job(threading.Thread, BaseModel):
# Send to cloudwatch # Send to cloudwatch
log_group = '/aws/batch/job' log_group = '/aws/batch/job'
stream_name = '{0}/default/{1}'.format(self.job_definition.name, self.job_id) stream_name = '{0}/default/{1}'.format(self.job_definition.name, self.job_id)
self.log_stream_name = stream_name
self._log_backend.ensure_log_group(log_group, None) self._log_backend.ensure_log_group(log_group, None)
self._log_backend.create_log_stream(log_group, stream_name) self._log_backend.create_log_stream(log_group, stream_name)
self._log_backend.put_log_events(log_group, stream_name, logs, None) self._log_backend.put_log_events(log_group, stream_name, logs, None)