"""streamparse.ext.invoke

invoke tasks that are imported into a project's task.py.

Should be used like this::

    from invoke import task, run
    from streamparse.ext.invoke import *

    # your other tasks
"""
from __future__ import absolute_import

from invoke import run, task

__all__ = ["stormlocal"]

@task
def stormlocal(topology=None):
    run("lein run -s {}".format(topology))

@@ -341,16 +341,102 @@
 =None):%0A
+    run(%22mkdir -p _resources/resources%22)%0A    run(%22cp src/*.py _resources/resources/%22)%0A
     run(

make invoke copy the python files before running stormlocal