Unable to acquire orchestrator lock. Transition currently in progress. #1010
Comments
jamesonwilliams
changed the title
|
@richardmcclellan was working on this as of this morning. @richardmcclellan are we tracking this in another issue already -- should we close this as as duplicate? The workaround I proposed was to do: Amplify.DataStore.subscribe(HubChannel.DataStore,
{ DataStoreChannelEventName.READY.toString() == it.name },
{ startUsingDataStore() }
)
fun startUsingDataStore() {
// Call your code above, here.
}This is a workaround until we fix the bug. |
|
cause=DataStoreException{message=Timed out acquiring orchestrator lock., cause=null, recoverySuggestion=Retry your request.}, recoverySuggestion=Retry.} |
|
I/amplify:aws-datastore(12127): Orchestrator lock acquired. **********could anybody help me to resolve it |
|
2022, |
|
I'm still seeing this error x2 Any updated? |
|
Any updated? |
|
@ntalamdotcom @3nd3rs0nn curious what version of Amplify and the shape of your schemas? Please let us know so that we can reproduce this internally. If not on the latest version already, please upgrade and let us know if the issue still persists. |
|
@chrisbonifacio I'm using amplify_core: 0.6.6
amplify_flutter: 0.6.6
amplify_auth_cognito: 0.6.6
amplify_api: 0.6.6
amplify_datastore: 0.6.6This is an example of one of the models I'm using: /*
* Copyright 2021 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
// NOTE: This file is generated and may not follow lint rules defined in your app
// Generated files can be excluded from analysis in analysis_options.yaml
// For more info, see: https://dart.dev/guides/language/analysis-options#excluding-code-from-analysis
// ignore_for_file: public_member_api_docs, annotate_overrides, dead_code, dead_codepublic_member_api_docs, depend_on_referenced_packages, file_names, library_private_types_in_public_api, no_leading_underscores_for_library_prefixes, no_leading_underscores_for_local_identifiers, non_constant_identifier_names, null_check_on_nullable_type_parameter, prefer_adjacent_string_concatenation, prefer_const_constructors, prefer_if_null_operators, prefer_interpolation_to_compose_strings, slash_for_doc_comments, sort_child_properties_last, unnecessary_const, unnecessary_constructor_name, unnecessary_late, unnecessary_new, unnecessary_null_aware_assignments, unnecessary_nullable_for_final_variable_declarations, unnecessary_string_interpolations, use_build_context_synchronously
import 'package:amplify_core/amplify_core.dart';
import 'package:collection/collection.dart';
import 'package:flutter/foundation.dart';
/** This is an auto generated class representing the AddMoreEvidence type in your schema. */
@immutable
class AddMoreEvidence extends Model {
static const classType = const _AddMoreEvidenceModelType();
final String id;
final int? _deliveryRoutePointId;
final List<String>? _evidences;
final int? _deliveryRouteId;
final int? _deliveryRoutePointStateId;
final TemporalDateTime? _createdAt;
final TemporalDateTime? _updatedAt;
@override
getInstanceType() => classType;
@override
String getId() {
return id;
}
int get deliveryRoutePointId {
try {
return _deliveryRoutePointId!;
} catch(e) {
throw new AmplifyCodeGenModelException(
AmplifyExceptionMessages.codeGenRequiredFieldForceCastExceptionMessage,
recoverySuggestion:
AmplifyExceptionMessages.codeGenRequiredFieldForceCastRecoverySuggestion,
underlyingException: e.toString()
);
}
}
List<String>? get evidences {
return _evidences;
}
int get deliveryRouteId {
try {
return _deliveryRouteId!;
} catch(e) {
throw new AmplifyCodeGenModelException(
AmplifyExceptionMessages.codeGenRequiredFieldForceCastExceptionMessage,
recoverySuggestion:
AmplifyExceptionMessages.codeGenRequiredFieldForceCastRecoverySuggestion,
underlyingException: e.toString()
);
}
}
int get deliveryRoutePointStateId {
try {
return _deliveryRoutePointStateId!;
} catch(e) {
throw new AmplifyCodeGenModelException(
AmplifyExceptionMessages.codeGenRequiredFieldForceCastExceptionMessage,
recoverySuggestion:
AmplifyExceptionMessages.codeGenRequiredFieldForceCastRecoverySuggestion,
underlyingException: e.toString()
);
}
}
TemporalDateTime? get createdAt {
return _createdAt;
}
TemporalDateTime? get updatedAt {
return _updatedAt;
}
const AddMoreEvidence._internal({required this.id, required deliveryRoutePointId, evidences, required deliveryRouteId, required deliveryRoutePointStateId, createdAt, updatedAt}): _deliveryRoutePointId = deliveryRoutePointId, _evidences = evidences, _deliveryRouteId = deliveryRouteId, _deliveryRoutePointStateId = deliveryRoutePointStateId, _createdAt = createdAt, _updatedAt = updatedAt;
factory AddMoreEvidence({String? id, required int deliveryRoutePointId, List<String>? evidences, required int deliveryRouteId, required int deliveryRoutePointStateId}) {
return AddMoreEvidence._internal(
id: id == null ? UUID.getUUID() : id,
deliveryRoutePointId: deliveryRoutePointId,
evidences: evidences != null ? List<String>.unmodifiable(evidences) : evidences,
deliveryRouteId: deliveryRouteId,
deliveryRoutePointStateId: deliveryRoutePointStateId);
}
bool equals(Object other) {
return this == other;
}
@override
bool operator ==(Object other) {
if (identical(other, this)) return true;
return other is AddMoreEvidence &&
id == other.id &&
_deliveryRoutePointId == other._deliveryRoutePointId &&
DeepCollectionEquality().equals(_evidences, other._evidences) &&
_deliveryRouteId == other._deliveryRouteId &&
_deliveryRoutePointStateId == other._deliveryRoutePointStateId;
}
@override
int get hashCode => toString().hashCode;
@override
String toString() {
var buffer = new StringBuffer();
buffer.write("AddMoreEvidence {");
buffer.write("id=" + "$id" + ", ");
buffer.write("deliveryRoutePointId=" + (_deliveryRoutePointId != null ? _deliveryRoutePointId!.toString() : "null") + ", ");
buffer.write("evidences=" + (_evidences != null ? _evidences!.toString() : "null") + ", ");
buffer.write("deliveryRouteId=" + (_deliveryRouteId != null ? _deliveryRouteId!.toString() : "null") + ", ");
buffer.write("deliveryRoutePointStateId=" + (_deliveryRoutePointStateId != null ? _deliveryRoutePointStateId!.toString() : "null") + ", ");
buffer.write("createdAt=" + (_createdAt != null ? _createdAt!.format() : "null") + ", ");
buffer.write("updatedAt=" + (_updatedAt != null ? _updatedAt!.format() : "null"));
buffer.write("}");
return buffer.toString();
}
AddMoreEvidence copyWith({String? id, int? deliveryRoutePointId, List<String>? evidences, int? deliveryRouteId, int? deliveryRoutePointStateId}) {
return AddMoreEvidence._internal(
id: id ?? this.id,
deliveryRoutePointId: deliveryRoutePointId ?? this.deliveryRoutePointId,
evidences: evidences ?? this.evidences,
deliveryRouteId: deliveryRouteId ?? this.deliveryRouteId,
deliveryRoutePointStateId: deliveryRoutePointStateId ?? this.deliveryRoutePointStateId);
}
AddMoreEvidence.fromJson(Map<String, dynamic> json)
: id = json['id'],
_deliveryRoutePointId = (json['deliveryRoutePointId'] as num?)?.toInt(),
_evidences = json['evidences']?.cast<String>(),
_deliveryRouteId = (json['deliveryRouteId'] as num?)?.toInt(),
_deliveryRoutePointStateId = (json['deliveryRoutePointStateId'] as num?)?.toInt(),
_createdAt = json['createdAt'] != null ? TemporalDateTime.fromString(json['createdAt']) : null,
_updatedAt = json['updatedAt'] != null ? TemporalDateTime.fromString(json['updatedAt']) : null;
Map<String, dynamic> toJson() => {
'id': id, 'deliveryRoutePointId': _deliveryRoutePointId, 'evidences': _evidences, 'deliveryRouteId': _deliveryRouteId, 'deliveryRoutePointStateId': _deliveryRoutePointStateId, 'createdAt': _createdAt?.format(), 'updatedAt': _updatedAt?.format()
};
static final QueryField ID = QueryField(fieldName: "id");
static final QueryField DELIVERYROUTEPOINTID = QueryField(fieldName: "deliveryRoutePointId");
static final QueryField EVIDENCES = QueryField(fieldName: "evidences");
static final QueryField DELIVERYROUTEID = QueryField(fieldName: "deliveryRouteId");
static final QueryField DELIVERYROUTEPOINTSTATEID = QueryField(fieldName: "deliveryRoutePointStateId");
static var schema = Model.defineSchema(define: (ModelSchemaDefinition modelSchemaDefinition) {
modelSchemaDefinition.name = "AddMoreEvidence";
modelSchemaDefinition.pluralName = "AddMoreEvidences";
modelSchemaDefinition.authRules = [
AuthRule(
authStrategy: AuthStrategy.PRIVATE,
operations: [
ModelOperation.CREATE,
ModelOperation.UPDATE,
ModelOperation.DELETE,
ModelOperation.READ
])
];
modelSchemaDefinition.addField(ModelFieldDefinition.id());
modelSchemaDefinition.addField(ModelFieldDefinition.field(
key: AddMoreEvidence.DELIVERYROUTEPOINTID,
isRequired: true,
ofType: ModelFieldType(ModelFieldTypeEnum.int)
));
modelSchemaDefinition.addField(ModelFieldDefinition.field(
key: AddMoreEvidence.EVIDENCES,
isRequired: false,
isArray: true,
ofType: ModelFieldType(ModelFieldTypeEnum.collection, ofModelName: describeEnum(ModelFieldTypeEnum.string))
));
modelSchemaDefinition.addField(ModelFieldDefinition.field(
key: AddMoreEvidence.DELIVERYROUTEID,
isRequired: true,
ofType: ModelFieldType(ModelFieldTypeEnum.int)
));
modelSchemaDefinition.addField(ModelFieldDefinition.field(
key: AddMoreEvidence.DELIVERYROUTEPOINTSTATEID,
isRequired: true,
ofType: ModelFieldType(ModelFieldTypeEnum.int)
));
modelSchemaDefinition.addField(ModelFieldDefinition.nonQueryField(
fieldName: 'createdAt',
isRequired: false,
isReadOnly: true,
ofType: ModelFieldType(ModelFieldTypeEnum.dateTime)
));
modelSchemaDefinition.addField(ModelFieldDefinition.nonQueryField(
fieldName: 'updatedAt',
isRequired: false,
isReadOnly: true,
ofType: ModelFieldType(ModelFieldTypeEnum.dateTime)
));
});
}
class _AddMoreEvidenceModelType extends ModelType<AddMoreEvidence> {
const _AddMoreEvidenceModelType();
@override
AddMoreEvidence fromJson(Map<String, dynamic> jsonData) {
return AddMoreEvidence.fromJson(jsonData);
}
}> flutter doctor -v
Doctor summary (to see all details, run flutter doctor -v):
[✓] Flutter (Channel stable, 2.10.4, on Ubuntu 22.04.1 LTS 5.15.0-47-generic, locale es_CO.UTF-8)
[✓] Android toolchain - develop for Android devices (Android SDK version 33.0.0)
[✓] Chrome - develop for the web
[✓] Android Studio (version 2021.2)
[✓] VS Code (version 1.70.2)
[✓] Connected device (2 available)
[✓] HTTP Host Availability
• No issues found!Steps to reproduce the error:
The behavior is that the app freezes and after in FirebaseCrashlytics I can view this error: |
|
change auth table from schema.graphql to this type User @model @auth(rules: [{allow: public}]) { |
|
There are a number of transition threading fixes that have been released since this ticket was last commented on. I'm going to go ahead and close this for now, but please let us know if issues persist with the last versions of Amplify Android v2 and we will continue researching. |
|
While creating M:N relationships, I get an error:
@jamesonwilliams suggested a work-around to require a DataStore.
READYevent to be set before relationship creation. We agreed the work-around shouldn't be necessary.When I run this code:
I get this crash:
The text was updated successfully, but these errors were encountered: