def _get_job_metrics(self):
cms = {}<EOL>for op in self.job.get_operators():<EOL><INDENT>metrics = op.get_metrics(name=sttrt.Condition._METRIC_PREFIX + '<STR_LIT:*>')<EOL>for m in metrics:<EOL><INDENT>cms[m.name] = m<EOL><DEDENT><DEDENT>return cms<EOL>
Fetch all the condition metrics for a job.
        We refetch the metrics each time to ensure that we don't miss
        any being added, e.g. if an operator is slow to start.