@@ -30,7 +30,8 @@ public TestPlugin(
3030
3131 _logger = logger ?? throw new ArgumentNullException ( nameof ( logger ) ) ;
3232 _messageBrokerPublisherService = messageBrokerPublisherService ?? throw new ArgumentNullException ( nameof ( messageBrokerPublisherService ) ) ;
33-
33+ _executeTaskStatus = string . Empty ;
34+ _getStatusStatus = string . Empty ;
3435 ValidateEventAndInit ( ) ;
3536 Initialize ( ) ;
3637 }
@@ -64,40 +65,40 @@ private void ValidateEventAndInit()
6465 }
6566 }
6667
67- public override async Task < ExecutionStatus > ExecuteTask ( CancellationToken cancellationToken = default )
68+ public override Task < ExecutionStatus > ExecuteTask ( CancellationToken cancellationToken = default )
6869 {
6970 if ( _executeTaskStatus . ToLower ( ) == "succeeded" )
7071 {
71- return new ExecutionStatus { Status = TaskExecutionStatus . Succeeded , FailureReason = FailureReason . None } ;
72+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Succeeded , FailureReason = FailureReason . None } ) ;
7273 }
7374 else if ( _executeTaskStatus . ToLower ( ) == "failed" )
7475 {
75- return new ExecutionStatus { Status = TaskExecutionStatus . Failed , FailureReason = FailureReason . PluginError } ;
76+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Failed , FailureReason = FailureReason . PluginError } ) ;
7677 }
7778 else if ( _executeTaskStatus . ToLower ( ) == "cancelled" )
7879 {
79- return new ExecutionStatus { Status = TaskExecutionStatus . Canceled , FailureReason = FailureReason . None } ;
80+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Canceled , FailureReason = FailureReason . None } ) ;
8081 }
8182
82- return new ExecutionStatus { Status = TaskExecutionStatus . Accepted , FailureReason = FailureReason . None } ;
83+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Accepted , FailureReason = FailureReason . None } ) ;
8384 }
8485
85- public override async Task < ExecutionStatus > GetStatus ( string identity , CancellationToken cancellationToken = default )
86+ public override Task < ExecutionStatus > GetStatus ( string identity , CancellationToken cancellationToken = default )
8687 {
8788 if ( _getStatusStatus . ToLower ( ) == "accepted" )
8889 {
89- return new ExecutionStatus { Status = TaskExecutionStatus . Accepted , FailureReason = FailureReason . None } ;
90+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Accepted , FailureReason = FailureReason . None } ) ;
9091 }
9192 else if ( _getStatusStatus . ToLower ( ) == "failed" )
9293 {
93- return new ExecutionStatus { Status = TaskExecutionStatus . Failed , FailureReason = FailureReason . PluginError } ;
94+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Failed , FailureReason = FailureReason . PluginError } ) ;
9495 }
9596 else if ( _getStatusStatus . ToLower ( ) == "cancelled" )
9697 {
97- return new ExecutionStatus { Status = TaskExecutionStatus . Canceled , FailureReason = FailureReason . None } ;
98+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Canceled , FailureReason = FailureReason . None } ) ;
9899 }
99100
100- return new ExecutionStatus { Status = TaskExecutionStatus . Succeeded , FailureReason = FailureReason . None } ;
101+ return Task . FromResult ( new ExecutionStatus { Status = TaskExecutionStatus . Succeeded , FailureReason = FailureReason . None } ) ;
101102 }
102103 ~ TestPlugin ( ) => Dispose ( disposing : false ) ;
103104
0 commit comments