Typo in initialization in demo.py

gregbaker / spark-celery

Helper to allow Python Celery tasks to do work in a Spark job.

Apache License 2.0

27 stars 6 forks source link

Typo in initialization in demo.py #4

Closed LinuxIsCool closed 6 years ago

LinuxIsCool commented 6 years ago

Line 15 keyword arg sparkconfig_builder should be sparkconf_builder: app = SparkCeleryApp(broker=BROKER_URL, backend=BACKEND_URL, sparkconfig_builder=sparkconfig_builder) Should be app = SparkCeleryApp(broker=BROKER_URL, backend=BACKEND_URL, sparkconf_builder=sparkconfig_builder)