File tree 1 file changed +3
-1
lines changed
1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -1017,6 +1017,8 @@ def _process_pending(
1017
1017
if subsequent_result_record .stream_record .errors :
1018
1018
continue
1019
1019
incremental_result = IncrementalStreamResult (
1020
+ # safe because `items` is always defined
1021
+ # when the record is completed
1020
1022
subsequent_result_record .items ,
1021
1023
# safe because `id` is defined
1022
1024
# once the stream has been released as pending
@@ -1068,6 +1070,7 @@ def _get_incremental_defer_result(
1068
1070
sub_path = deferred_grouped_field_set_record .path [len (longest_path ) :]
1069
1071
id_ = record_with_longest_path .id
1070
1072
return IncrementalDeferResult (
1073
+ # safe because `data` is always defined when the record is completed
1071
1074
data , # type: ignore
1072
1075
# safe because `id` is defined
1073
1076
# once the fragment has been released as pending
@@ -1298,7 +1301,6 @@ def __init__(
1298
1301
self .errors = []
1299
1302
self .is_completed_async_iterator = self .is_completed = False
1300
1303
self .is_final_record = self .filtered = False
1301
- self .items = []
1302
1304
1303
1305
def __repr__ (self ) -> str :
1304
1306
name = self .__class__ .__name__
You can’t perform that action at this time.
0 commit comments