kopia lustrzana https://github.com/bugout-dev/moonstream
Remove print.
rodzic
27aa0ce3a5
commit
f598596f07
|
@ -242,7 +242,6 @@ def previous_event(
|
||||||
max_workers=max_threads, thread_name_prefix="event_providers_"
|
max_workers=max_threads, thread_name_prefix="event_providers_"
|
||||||
) as executor:
|
) as executor:
|
||||||
for provider_name, provider in event_providers.items():
|
for provider_name, provider in event_providers.items():
|
||||||
print(provider_name, provider)
|
|
||||||
futures[provider_name] = executor.submit(
|
futures[provider_name] = executor.submit(
|
||||||
provider.previous_event,
|
provider.previous_event,
|
||||||
db_session,
|
db_session,
|
||||||
|
@ -253,7 +252,6 @@ def previous_event(
|
||||||
query,
|
query,
|
||||||
user_subscriptions,
|
user_subscriptions,
|
||||||
)
|
)
|
||||||
print(user_subscriptions)
|
|
||||||
|
|
||||||
results: Dict[str, data.Event] = {}
|
results: Dict[str, data.Event] = {}
|
||||||
for provider_name, future in futures.items():
|
for provider_name, future in futures.items():
|
||||||
|
|
Ładowanie…
Reference in New Issue