pathology/orchestrator/pathology_cohorts_handler.py [2322:2342]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    )
    # Generate DpasOperationId and store in Spanner.
    try:
      dpas_op_id = self._spanner_client.run_in_transaction(
          _record_operation_in_table,
          json_response['name'],
          op_metadata,
          request.notification_emails,
      )
    except Exception as exc:
      if exc.__class__ is rpc_status.RpcFailureError:
        raise exc
      raise rpc_status.RpcFailureError(
          rpc_status.build_rpc_method_status_and_log(
              grpc.StatusCode.INTERNAL,
              'Failed to record operation in table.',
              exp=exc,
          )
      ) from exc

    cloud_logging_client.info(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pathology/orchestrator/pathology_cohorts_handler.py [2511:2531]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    )
    # Generate DpasOperationId and store in Spanner.
    try:
      dpas_op_id = self._spanner_client.run_in_transaction(
          _record_operation_in_table,
          json_response['name'],
          op_metadata,
          request.notification_emails,
      )
    except Exception as exc:
      if exc.__class__ is rpc_status.RpcFailureError:
        raise exc
      raise rpc_status.RpcFailureError(
          rpc_status.build_rpc_method_status_and_log(
              grpc.StatusCode.INTERNAL,
              'Failed to record operation in table.',
              exp=exc,
          )
      ) from exc

    cloud_logging_client.info(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -