Object getFromStep(String stepId, String paramName) {
    try {
      return executor
          .submit(() -> fromStep(stepId, paramName))
          .get(TIMEOUT_IN_MILLIS, TimeUnit.MILLISECONDS);
    } catch (Exception e) {
      throw new MaestroInternalError(
          e, "getFromStep throws an exception for stepId=[%s], paramName=[%s]", stepId, paramName);
    }
  }
@Test
  public void testGetFromStepThrowsErrorWhenInvokedFromWorkflowExecContext() {
    when(instanceWrapper.isWorkflowParam()).thenReturn(true);
    AssertHelper.assertThrows(
        "Invalid field",
        MaestroInternalError.class,
        "getFromStep throws an exception fieldName=[step_id]",
        () -> paramExtension.getFromStep(Constants.STEP_ID_PARAM));
  }