if (op_reg_data->shape_inference_fn == nullptr) {
    status->status =
        InvalidArgument("No shape inference function exists for op '",
                        node_def.op(), "', did you forget to define it?");
    return;
  }

  status->status = c.Run(op_reg_data->shape_inference_fn);
  if (!status->status.ok()) return;

  // Set output_shapes.

        },
        "danish_keywords": {
          "type":       "keyword_marker",
          "keywords": ["Hej", "verden", "Søg"]

        },
        "danish_keywords": {
          "type":       "keyword_marker",
          "keywords": ["Hej", "verden", "Søg"]

      throw new AssertionError(e);
    }

    if (referenceException == null) {
      if (targetException != null) {
        throw new AssertionError("Target threw exception when reference did not", targetException);
      }

      /*
       * Reference iterator returned a value, so we should expect the
       * same value from the target
       */

			hosts: hostMap,
			disks: diskMap,
			jobID: jobID,
			depID: dID,
		})
		m.Merge(&mLocal)
		// Allow half the interval for collecting remote...
		cctx, cancel := context.WithTimeout(ctx, interval/2)
		mRemote := collectRemoteMetrics(cctx, types, collectMetricsOpts{
			hosts: hostMap,
			disks: diskMap,
			jobID: jobID,
			depID: dID,
		})
		cancel()
		m.Merge(&mRemote)
		if !byHost {

      throw new AssertionError(e);
    }

    if (referenceException == null) {
      if (targetException != null) {
        throw new AssertionError("Target threw exception when reference did not", targetException);
      }

      /*
       * Reference iterator returned a value, so we should expect the
       * same value from the target
       */

        throw failure;
      }

      if (snapshot.shutdownWhenStartupFinishes) {
        snapshot = new StateSnapshot(STOPPING);
        // We don't call listeners here because we already did that when we set the
        // shutdownWhenStartupFinishes flag.
        doStop();
      } else {
        snapshot = new StateSnapshot(RUNNING);
        enqueueRunningEvent();
      }
    } finally {

	p := Product6{
		Name: "unique_code",
		Item: &ProductItem2{},
	}
	_DB.Model(&Product6{}).Create(&p)

	if err := _DB.Unscoped().Delete(&p).Error; err != nil {
		t.Fatalf("unscoped did not propagate")
	}

     * for the field accesses in MapIteratorCache. This test *has* found other TSAN errors,
     * including in MapRetrievalCache, so I'm not sure why this one is different. I did at least
     * confirm that my change to MapIteratorCache fixes the TSAN error in the (larger) test it was
     * originally reported in.
     */
    for (Future<?> future : futures.build()) {
      future.get();

    SUCCESS,

    /** The method returned false. */
    FAILURE,

    /** The method threw an InterruptedException. */
    INTERRUPT,

    /** The method did not return or throw anything. */
    HANG;

    @Override
    public String toString() {
      return CaseFormat.UPPER_UNDERSCORE.to(CaseFormat.UPPER_CAMEL, name());
    }
  }