<reponame>globophobe/crypto-tick-data
from cryptofeed_werks.api import trade_aggregator

from ..base import Command as BaseCommand


class Command(BaseCommand):
    help = "Aggregate trades"

    def handle(self, *args, **options) -> None:
        kwargs = super().handle(*args, **options)
        if kwargs is not None:
            trade_aggregator(**kwargs)

from cryptofeed_werks.api import trade_aggregator

from ..base import Command as BaseCommand


class Command(BaseCommand):
    help = "Aggregate trades"

    def handle(self, *args, **options) -> None:
        kwargs = super().handle(*args, **options)
        if kwargs is not None:
            trade_aggregator(**kwargs)