Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
Chaithra-07 committed Mar 19, 2024
2 parents 0970dcf + bf4c1fc commit fa032b8
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 37 deletions.
10 changes: 0 additions & 10 deletions Conductor/Api/IIntegrationResourceApi.cs
Original file line number Diff line number Diff line change
Expand Up @@ -119,16 +119,6 @@ public interface IIntegrationResourceApi : IApiAccessor
/// <returns>Integration</returns>
Integration GetIntegrationProvider(string name);

/// <summary>
/// Get Integration provider definitions
/// </summary>
/// <remarks>
///
/// </remarks>
/// <exception cref="ApiException">Thrown when fails to make API call</exception>
/// <returns>List<IntegrationDef></returns>
List<IntegrationDef> GetIntegrationProviderDefs();

/// <summary>
/// Get all Integrations Providers
/// </summary>
Expand Down
2 changes: 1 addition & 1 deletion Conductor/Client/ApiClient.cs
Original file line number Diff line number Diff line change
Expand Up @@ -382,7 +382,7 @@ public object Deserialize(RestResponse response, Type type)
}
catch (Exception e)
{
throw new ApiException(500, e.Message);
throw new ApiException(500, e.Message, e);
}
}

Expand Down
25 changes: 0 additions & 25 deletions Tests/Api/IntegrationResourceApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -235,31 +235,6 @@ public async void DeleteAnIntegrationAsyncTest()
Assert.Null(exception);
_performCleanup = false;
}

/// <summary>
/// Test GetIntegrationProviderDefs
/// </summary>
[Fact]
public void GetIntegrationProviderDefs()
{
Setup();
var response = _integrationResourceApi.GetIntegrationProviderDefs();
AssertExtensions.AssertModelResponse<List<IntegrationDef>>(response);
_performCleanup = true;
}

/// <summary>
/// Test GetIntegrationProviderDefsAsync
/// </summary>
[Fact]
public async void GetIntegrationProviderDefsAsync()
{
Setup();
var response = await _integrationResourceApi.GetIntegrationProviderDefsAsync();
AssertExtensions.AssertModelResponse<List<IntegrationDef>>(response);
_performCleanup = true;
}

/// <summary>
/// Test DeleteIntegrationProvider
/// </summary>
Expand Down
6 changes: 5 additions & 1 deletion Tests/Api/WorkflowResourceApiTest.cs
Original file line number Diff line number Diff line change
Expand Up @@ -272,13 +272,17 @@ public void TestWorkflowOperations()

workflow = _workflowClient.GetWorkflow(workflowId, true);

System.Threading.Thread.Sleep(5000);

// There should be 3 tasks
_testOutputHelper.WriteLine(
$"Number of tasks in workflow is {workflow.Tasks.Count} and last task is {workflow.Tasks.Last().ReferenceTaskName}");
Assert.Equal(3, workflow.Tasks.Count);

_testOutputHelper.WriteLine("Searching for correlationId " + correlationId);
// Search for workflows
var searchResults = _workflowClient.Search(start: 0, size: 100, freeText: "*",
var startTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds() * 1000;
var searchResults = _workflowClient.Search(start: 0, size: 10, freeText: "*",
query: $"correlationId = '{correlationId}'");
_testOutputHelper.WriteLine(
$"Found {searchResults.Results.Count} execution with correlation_id '{correlationId}'");
Expand Down

0 comments on commit fa032b8

Please sign in to comment.