BaseIntegration.__call__ → BaseIntegration()
This commit is contained in:
parent
f048cf07a9
commit
8b7c381870
|
@ -49,10 +49,6 @@ async def execute_integrations(
|
||||||
status: Status, sinks: List[FilteredIntegration]
|
status: Status, sinks: List[FilteredIntegration]
|
||||||
) -> List[Optional[str]]:
|
) -> List[Optional[str]]:
|
||||||
return await gather(
|
return await gather(
|
||||||
*[
|
*[sink[0](status) for sink in sinks if run_filters(sink[1], status)],
|
||||||
sink[0].__call__(status)
|
|
||||||
for sink in sinks
|
|
||||||
if run_filters(sink[1], status)
|
|
||||||
],
|
|
||||||
return_exceptions=True,
|
return_exceptions=True,
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in New Issue