added test for pipeline with code step

[OriHoch]

Seems the code step is not working, added a test to prove it

[OriHoch]

can see the failure here - https://travis-ci.org/frictionlessdata/datapackage-pipelines/builds/349780173#L971

E       AssertionError: Failed results: ['./tests/env/dummy/pipeline-test-code init, Invalid Pipeline: \'run\' is a required property\n\nFailed validating \'required\' in schema[\'properties\'][\'pipeline\'][\'items\']:\n    {\'properties\': {\'cache\': {\'type\': \'boolean\'},\n                    \'parameters\': {\'type\': \'object\'},\n                    \'run\': {\'type\': \'string\'},\n                    \'validate\': {\'type\': \'booelan\'}},\n     \'required\': [\'run\'],\n     \'type\': \'object\'}\n\nOn instance[\'pipeline\'][1]:\n    {\'code\': \'from datapackage_pipelines.wrapper import ingest, spew\\n\'\n             \'parameters, datapackage, resources, stats = ingest() + \'\n             \'({},)\\n\'\n             \'def get_resource():\\n\'\n             \'  for descriptor, resource in zip(datapackage["resources"], \'\n             \'resources):\\n\'\n             \'    for row in resource:\\n\'\n             \'      yield row\\n\'\n             \'spew(datapackage, [get_resource()], stats)\\n\'}']

[akariv]

Yes, I think that originally it was used alongside the 'run' parameter and not as a replacement. We could modify the schema to require one of 'run' or 'code' to support removing that parameter completely.

…

On Tue, Mar 6, 2018 at 2:39 PM Ori Hoch ***@***.***> wrote: can see the failure here - https://travis-ci.org/frictionlessdata/datapackage-pipelines/builds/349780173#L971 E AssertionError: Failed results: ['./tests/env/dummy/pipeline-test-code init, Invalid Pipeline: \'run\' is a required property\n\nFailed validating \'required\' in schema[\'properties\'][\'pipeline\'][\'items\']:\n {\'properties\': {\'cache\': {\'type\': \'boolean\'},\n \'parameters\': {\'type\': \'object\'},\n \'run\': {\'type\': \'string\'},\n \'validate\': {\'type\': \'booelan\'}},\n \'required\': [\'run\'],\n \'type\': \'object\'}\n\nOn instance[\'pipeline\'][1]:\n {\'code\': \'from datapackage_pipelines.wrapper import ingest, spew\\n\'\n \'parameters, datapackage, resources, stats = ingest() + \'\n \'({},)\\n\'\n \'def get_resource():\\n\'\n \' for descriptor, resource in zip(datapackage["resources"], \'\n \'resources):\\n\'\n \' for row in resource:\\n\'\n \' yield row\\n\'\n \'spew(datapackage, [get_resource()], stats)\\n\'}'] — You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub <#123 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AAQMdUR6_ikhTxCmaTt7skETpSUGSG0aks5tboOSgaJpZM4Sel4u> .

[OriHoch]

👍 fixed the test

[coveralls]

Pull Request Test Coverage Report for Build 879

• 0 of 0 changed or added relevant lines in 0 files are covered.
• No unchanged relevant lines lost coverage.
• Overall coverage remained the same at ?%

---

Totals
Change from base Build 878:	0.0%
Covered Lines:
Relevant Lines:	0

---

💛 - Coveralls