@Test
public void getMappedTasks_WithoutTaskDef() {

	//Given
	WorkflowTask taskToSchedule = new WorkflowTask();
	taskToSchedule.setName("kafka_task");
	taskToSchedule.setType(TaskType.KAFKA_PUBLISH.name());
	String taskId = IDGenerator.generate();
	String retriedTaskId = IDGenerator.generate();
	Workflow workflow = new Workflow();
	WorkflowDef workflowDef = new WorkflowDef();
	workflow.setWorkflowDefinition(workflowDef);
	TaskDef taskdefinition = new TaskDef();
	String testExecutionNameSpace = "testExecutionNameSpace";
	taskdefinition.setExecutionNameSpace(testExecutionNameSpace);
	String testIsolationGroupId = "testIsolationGroupId";
	taskdefinition.setIsolationGroupId(testIsolationGroupId);
	TaskMapperContext taskMapperContext = TaskMapperContext.newBuilder()
			.withWorkflowDefinition(workflowDef)
			.withWorkflowInstance(workflow)
			.withTaskDefinition(taskdefinition)
			.withTaskToSchedule(taskToSchedule)
			.withTaskInput(new HashMap<>())
			.withRetryCount(0)
			.withRetryTaskId(retriedTaskId)
			.withTaskId(taskId)
			.build();
	//when
	List<Task> mappedTasks = kafkaTaskMapper.getMappedTasks(taskMapperContext);
	//Then
	assertEquals(1, mappedTasks.size());
	assertEquals(TaskType.KAFKA_PUBLISH.name(), mappedTasks.get(0).getTaskType());
	assertEquals(testExecutionNameSpace, mappedTasks.get(0).getExecutionNameSpace());
	assertEquals(testIsolationGroupId, mappedTasks.get(0).getIsolationGroupId());
}