from framework.celery_tasks import app as celery_app
from scripts.analytics.base import DateAnalyticsHarness
from scripts.analytics.node_log_events import NodeLogEvents


class EventAnalyticsHarness(DateAnalyticsHarness):

    @property
    def analytics_classes(self):
        return [NodeLogEvents]


@celery_app.task(name='scripts.run_keen_events')
def run_main(date):
    EventAnalyticsHarness().main(date)


if __name__ == '__main__':
    EventAnalyticsHarness().main()

from framework.celery_tasks import app as celery_app
from scripts.analytics.base import DateAnalyticsHarness
from scripts.analytics.node_log_events import NodeLogEvents
from scripts.analytics.user_domain_events import UserDomainEvents


class EventAnalyticsHarness(DateAnalyticsHarness):

    @property
    def analytics_classes(self):
        return [NodeLogEvents, UserDomainEvents]


@celery_app.task(name='scripts.run_keen_events')
def run_main(date):
    EventAnalyticsHarness().main(date)


if __name__ == '__main__':
    EventAnalyticsHarness().main()

Add new user domain event collector to main keen events script
Add new user domain event collector to main keen events script

  from framework.celery_tasks import app as celery_app
  from scripts.analytics.base import DateAnalyticsHarness
  from scripts.analytics.node_log_events import NodeLogEvents
+ from scripts.analytics.user_domain_events import UserDomainEvents
  
  
  class EventAnalyticsHarness(DateAnalyticsHarness):
  
      @property
      def analytics_classes(self):
-         return [NodeLogEvents]
+         return [NodeLogEvents, UserDomainEvents]
  
  
  @celery_app.task(name='scripts.run_keen_events')
  def run_main(date):
      EventAnalyticsHarness().main(date)
  
  
  if __name__ == '__main__':
      EventAnalyticsHarness().main()
  
Add new user domain event collector to main keen events script
## Code Before:
from framework.celery_tasks import app as celery_app
from scripts.analytics.base import DateAnalyticsHarness
from scripts.analytics.node_log_events import NodeLogEvents


class EventAnalyticsHarness(DateAnalyticsHarness):

    @property
    def analytics_classes(self):
        return [NodeLogEvents]


@celery_app.task(name='scripts.run_keen_events')
def run_main(date):
    EventAnalyticsHarness().main(date)


if __name__ == '__main__':
    EventAnalyticsHarness().main()

## Instruction:
Add new user domain event collector to main keen events script
## Code After:
from framework.celery_tasks import app as celery_app
from scripts.analytics.base import DateAnalyticsHarness
from scripts.analytics.node_log_events import NodeLogEvents
from scripts.analytics.user_domain_events import UserDomainEvents


class EventAnalyticsHarness(DateAnalyticsHarness):

    @property
    def analytics_classes(self):
        return [NodeLogEvents, UserDomainEvents]


@celery_app.task(name='scripts.run_keen_events')
def run_main(date):
    EventAnalyticsHarness().main(date)


if __name__ == '__main__':
    EventAnalyticsHarness().main()
