amplify-swift: DataStore fails to sync data

Describe the bug

Datastore is falling to sync data from the cloud with decoding errors.

Steps To Reproduce

1. Set up a clean project with the following auth: 
   2.1. Cognito as the primary auth and API Key as the secondary.
   2.1. Select to auto merge and resolve conflicts.
2. Complete setup and push
2. Ensure the cloud tables have data items.
3. Start the application.

Expected behavior

To pull and populate local datastore tables with data from the cloud.

Amplify Framework Version

1.17.0

Amplify Categories

API, Auth, DataStore

Dependency manager

Swift PM

Swift version

5.3.2

CLI version

7.6.3

Xcode version

12.4 (12D4e)

Relevant log output

2021-12-15 11:21:50.980256+0000 <APP_NAME>[39863:155273] [RetryableGraphQLSubscriptionOperation<MutationSync<AnyModel>>] APIError: Subscription item event failed with error
Caused by:
jsonParse(nil, Optional(Swift.DecodingError.dataCorrupted(Swift.DecodingError.Context(codingPath: [CodingKeys(stringValue: "type", intValue: nil)], debugDescription: "Cannot initialize RealtimeConnectionProviderResponseType from invalid String value connection_error", underlyingError: nil))))

Is this a regression?

No

Regression additional context

No response

Device

iPhone 12 Pro Simulator

iOS Version

iOS 14.4

Specific to simulators

No response

Additional context

Application Log ApplicationConsolLog.log

schema.graphql schema.txt

Plugin Configuration within AppDelegate

public var syncDate: Temporal.DateTime? = Temporal.DateTime.init(Date())

do {
            try Amplify.add(plugin: AWSCognitoAuthPlugin())
            
            let apiPlugin: AWSAPIPlugin = AWSAPIPlugin(modelRegistration: AmplifyModels())
            try Amplify.add(plugin: apiPlugin)
            
            var syncExpressions: [DataStoreSyncExpression] = []
            
            //sync two weeks worth of data
            let calendar: Calendar = .iso8601
            let date: Date = calendar.date(byAdding: .day, value: -14, to: Date().startOfWeek())!
            syncDate = Temporal.DateTime.init(date)
            let mealPlanSyncExpr: DataStoreSyncExpression = DataStoreSyncExpression.syncExpression(MealPlan.schema) {
                guard let syncDate = syncDate else {
                    return QueryPredicateConstant.all
                }
                return MealPlan.keys.startDateTime.ge(syncDate)
            }
            syncExpressions.append(mealPlanSyncExpr)
            
            let userProfileSyncExpr: DataStoreSyncExpression = DataStoreSyncExpression.syncExpression(UserProfile.schema) {
                return QueryPredicateConstant.all
            }
            syncExpressions.append(userProfileSyncExpr)
            
            let datastoreConfiguration: DataStoreConfiguration = DataStoreConfiguration.custom(syncExpressions: syncExpressions, authModeStrategy: .multiAuth)
            let dataStorePlugin: AWSDataStorePlugin = AWSDataStorePlugin(modelRegistration: AmplifyModels(),
                                                     configuration: datastoreConfiguration)
            
            try Amplify.add(plugin: dataStorePlugin)
            
            try Amplify.configure()
            logger?.log(type: .debug, category: .app, message: "Initialized Amplify")
            
        } catch {
            logger?.log(type: .error, category: .app, message: "Failed to initialize Amplify with \(error)")
        }