1763

Build # 1763

Build Type

push

buildkite

Committed by GitHub

Commit Message

Exposed startedEventAttribute and DataConverter (#799)

* exposing startedEventAttributes through DecisionContext in WorkflowInfo for using in ContinueAsNew

* addition of workflowEventAttributes in dummy implementation

* Addition of dataConverter

Run Details

8 of 8 new or added lines in 3 files covered. (100.0%)

11117 of 18404 relevant lines covered (60.41%)

0.6 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

62.5

/src/main/java/com/uber/cadence/internal/sync/WorkflowInfoImpl.java

/*
 *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 *  Modifications copyright (C) 2017 Uber Technologies, Inc.
 *
 *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
 *  use this file except in compliance with the License. A copy of the License is
 *  located at
 *
 *  http://aws.amazon.com/apache2.0
 *
 *  or in the "license" file accompanying this file. This file is distributed on
 *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 *  express or implied. See the License for the specific language governing
 *  permissions and limitations under the License.
 */

package com.uber.cadence.internal.sync;

import com.uber.cadence.SearchAttributes;
import com.uber.cadence.WorkflowExecution;
import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
import com.uber.cadence.converter.DataConverter;
import com.uber.cadence.internal.replay.DecisionContext;
import com.uber.cadence.workflow.WorkflowInfo;
import java.time.Duration;

final class WorkflowInfoImpl implements WorkflowInfo {

  private final DecisionContext context;

  WorkflowInfoImpl(DecisionContext context) {
    this.context = context;
  }

  @Override
  public String getDomain() {
    return context.getDomain();
  }

  @Override
  public String getWorkflowId() {
    return context.getWorkflowId();
  }

  @Override
  public String getRunId() {
    return context.getRunId();
  }

  @Override
  public String getWorkflowType() {
    return context.getWorkflowType().getName();
  }

  @Override
  public String getTaskList() {
    return context.getTaskList();
  }

  @Override
  public Duration getExecutionStartToCloseTimeout() {
    return context.getExecutionStartToCloseTimeout();
  }

  @Override
  public SearchAttributes getSearchAttributes() {
    return context.getSearchAttributes();
  }

  @Override
  public String getParentWorkflowId() {
    WorkflowExecution parentWorkflowExecution = context.getParentWorkflowExecution();
    return parentWorkflowExecution == null ? null : parentWorkflowExecution.getWorkflowId();
  }

  @Override
  public String getParentRunId() {
    WorkflowExecution parentWorkflowExecution = context.getParentWorkflowExecution();
    return parentWorkflowExecution == null ? null : parentWorkflowExecution.getRunId();
  }

  @Override
  public WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes() {
    return context.getWorkflowExecutionStartedEventAttributes();
  }

  @Override
  public DataConverter getDataConverter() {
    return context.getDataConverter();
  }
}

1	/*
2	* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3	*
4	* Modifications copyright (C) 2017 Uber Technologies, Inc.
5	*
6	* Licensed under the Apache License, Version 2.0 (the "License"). You may not
7	* use this file except in compliance with the License. A copy of the License is
8	* located at
9	*
10	* http://aws.amazon.com/apache2.0
11	*
12	* or in the "license" file accompanying this file. This file is distributed on
13	* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
14	* express or implied. See the License for the specific language governing
15	* permissions and limitations under the License.
16	*/
17
18	package com.uber.cadence.internal.sync;
19
20	import com.uber.cadence.SearchAttributes;
21	import com.uber.cadence.WorkflowExecution;
22	import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
23	import com.uber.cadence.converter.DataConverter;
24	import com.uber.cadence.internal.replay.DecisionContext;
25	import com.uber.cadence.workflow.WorkflowInfo;
26	import java.time.Duration;
27
28	final class WorkflowInfoImpl implements WorkflowInfo {
29
30	private final DecisionContext context;
31
32	WorkflowInfoImpl(DecisionContext context) {	1✔
33	this.context = context;	1✔
34	}	1✔
35
36	@Override
37	public String getDomain() {
38	return context.getDomain();	×
39	}
40
41	@Override
42	public String getWorkflowId() {
43	return context.getWorkflowId();	1✔
44	}
45
46	@Override
47	public String getRunId() {
48	return context.getRunId();	1✔
49	}
50
51	@Override
52	public String getWorkflowType() {
53	return context.getWorkflowType().getName();	1✔
54	}
55
56	@Override
57	public String getTaskList() {
58	return context.getTaskList();	1✔
59	}
60
61	@Override
62	public Duration getExecutionStartToCloseTimeout() {
63	return context.getExecutionStartToCloseTimeout();	×
64	}
65
66	@Override
67	public SearchAttributes getSearchAttributes() {
68	return context.getSearchAttributes();	1✔
69	}
70
71	@Override
72	public String getParentWorkflowId() {
73	WorkflowExecution parentWorkflowExecution = context.getParentWorkflowExecution();	1✔
74	return parentWorkflowExecution == null ? null : parentWorkflowExecution.getWorkflowId();	1✔
75	}
76
77	@Override
78	public String getParentRunId() {
79	WorkflowExecution parentWorkflowExecution = context.getParentWorkflowExecution();	×
80	return parentWorkflowExecution == null ? null : parentWorkflowExecution.getRunId();	×
81	}
82
83	@Override
84	public WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes() {
85	return context.getWorkflowExecutionStartedEventAttributes();	×
86	}
87
88	@Override
89	public DataConverter getDataConverter() {
90	return context.getDataConverter();	×
91	}
92	}

uber / cadence-java-client / 1763

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous