diff --git a/policy/policy_handler/async.go b/policy/policy_handler/async.go
index fd5e75a..c9cf2fe 100644
--- a/policy/policy_handler/async.go
+++ b/policy/policy_handler/async.go
@@ -92,7 +92,7 @@ func buildAsyncDataSources(multipleQuerySupport bool) dataSourceProvider {
 		if len(queryResponse.Errors) > 0 {
 			errorMessage := queryResponse.Errors[0].Message
 			if errorMessage == "An unexpected error has occurred" {
-				return nil, fmt.Errorf("async query contained error: %s", errorMessage).(types.RetryableExecutionError)
+				return nil, types.RetryableExecutionError(fmt.Sprintf("async query contained error: %s", errorMessage))
 			}
 			return nil, fmt.Errorf("async query contained error: %s", errorMessage)
 		}