diff --git a/system/service/dal_connection.go b/system/service/dal_connection.go
index a35565ff2..1d62cf8ca 100644
--- a/system/service/dal_connection.go
+++ b/system/service/dal_connection.go
@@ -93,7 +93,7 @@ func (svc *dalConnection) Create(ctx context.Context, new *types.DalConnection)
 
 		// validation
 		{
-			if new.Type != types.DalPrimaryConnectionResourceType {
+			if new.Type != types.DalConnectionResourceType {
 				// @todo error
 				err = fmt.Errorf("cannot create connection: unsupported connection type %s", new.Type)
 				return