@@ -113,20 +113,6 @@ def outstanding(self) -> int:
113
113
raise NotImplementedError ("Classes inheriting from BlockProviderExecutor must implement "
114
114
"outstanding()" )
115
115
116
- def status (self ) -> Dict [str , JobStatus ]:
117
- """Return the status of all jobs/blocks currently known to this executor.
118
-
119
- :return: a dictionary mapping block ids (in string) to job status
120
- """
121
- if self ._provider :
122
- block_ids , job_ids = self ._get_block_and_job_ids ()
123
- status = self ._make_status_dict (block_ids , self ._provider .status (job_ids ))
124
- else :
125
- status = {}
126
- status .update (self ._simulated_status )
127
-
128
- return status
129
-
130
116
def set_bad_state_and_fail_all (self , exception : Exception ):
131
117
"""Allows external error handlers to mark this executor as irrecoverably bad and cause
132
118
all tasks submitted to it now and in the future to fail. The executor is responsible
@@ -276,6 +262,20 @@ def poll_facade(self) -> None:
276
262
if delta_status :
277
263
self .send_monitoring_info (delta_status )
278
264
265
+ def status (self ) -> Dict [str , JobStatus ]:
266
+ """Return the status of all jobs/blocks currently known to this executor.
267
+
268
+ :return: a dictionary mapping block ids (in string) to job status
269
+ """
270
+ if self ._provider :
271
+ block_ids , job_ids = self ._get_block_and_job_ids ()
272
+ status = self ._make_status_dict (block_ids , self ._provider .status (job_ids ))
273
+ else :
274
+ status = {}
275
+ status .update (self ._simulated_status )
276
+
277
+ return status
278
+
279
279
@property
280
280
def status_facade (self ) -> Dict [str , JobStatus ]:
281
281
"""Return the status of all jobs/blocks of the executor of this poller.
0 commit comments