@@ -119,7 +119,7 @@ def test_crud(self):
119119 job .finalize ()
120120
121121 # Create a new job
122- job = jobs .create ("search * | head 1 | stats count" )
122+ job = jobs .create ("search * | head 1000 | stats count" )
123123 self .assertTrue (jobs .contains (job .sid ))
124124
125125 # Set various properties on it
@@ -164,7 +164,7 @@ def test_results(self):
164164 index = service .indexes ['_internal' ]
165165 self .assertTrue (index ['totalEventCount' ] > 0 )
166166
167- job = jobs .create ("search index=_internal | head 1 | stats count" )
167+ job = jobs .create ("search index=_internal | head 1000 | stats count" )
168168 self .assertRaises (ValueError , job .results )
169169 reader = results .ResultsReader (job .results (timeout = 60 ))
170170 job .refresh ()
@@ -174,17 +174,17 @@ def test_results(self):
174174
175175 result = reader .next ()
176176 self .assertTrue (isinstance (result , dict ))
177- self .assertEqual (int (result ["count" ]), 1 )
177+ self .assertLessEqual (int (result ["count" ]), 1000 )
178178
179179 # Repeat the same thing, but without the .is_preview reference.
180- job = jobs .create ("search index=_internal | head 1 | stats count" )
180+ job = jobs .create ("search index=_internal | head 1000 | stats count" )
181181 self .assertRaises (ValueError , job .results )
182182 reader = results .ResultsReader (job .results (timeout = 60 ))
183183 job .refresh ()
184184 self .assertEqual (job ['isDone' ], '1' )
185185 result = reader .next ()
186186 self .assertTrue (isinstance (result , dict ))
187- self .assertEqual (int (result ["count" ]), 1 )
187+ self .assertLessEqual (int (result ["count" ]), 1000 )
188188
189189 def test_results_reader (self ):
190190 # Run jobs.export("search index=_internal | stats count",
0 commit comments