This repository was archived by the owner on Jul 21, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 1414# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1515# See the License for the specific language governing permissions and
1616# limitations under the License.
17+ import asyncio
1718import copy
1819import importlib
1920import logging
2829from opentracing import Tracer
2930from opentracing .scope_managers .asyncio import AsyncioScopeManager
3031from twisted .internet import asyncioreactor , defer
31- from twisted .internet .defer import Deferred , ensureDeferred
32+ from twisted .internet .defer import Deferred
3233from twisted .internet .interfaces import (
3334 IReactorCore ,
3435 IReactorFDSet ,
@@ -225,7 +226,9 @@ def run(self) -> None:
225226 @defer .inlineCallbacks
226227 def start () -> Generator [Deferred [Any ], Any , Any ]:
227228 try :
228- yield ensureDeferred (self .make_pushkins_then_start ())
229+ yield Deferred .fromFuture (
230+ asyncio .ensure_future (self .make_pushkins_then_start ())
231+ )
229232 except Exception :
230233 # Print the exception and bail out.
231234 print ("Error during startup:" , file = sys .stderr )
You can’t perform that action at this time.
0 commit comments