In [1]:

    

import sys
sys.path


    

    
Out[1]:





['',
 '/home/safuser/miniconda/lib/python27.zip',
 '/home/safuser/miniconda/lib/python2.7',
 '/home/safuser/miniconda/lib/python2.7/plat-linux2',
 '/home/safuser/miniconda/lib/python2.7/lib-tk',
 '/home/safuser/miniconda/lib/python2.7/lib-old',
 '/home/safuser/miniconda/lib/python2.7/lib-dynload',
 '/home/safuser/miniconda/lib/python2.7/site-packages',
 '/home/safuser/miniconda/lib/python2.7/site-packages/PIL',
 '/home/safuser/miniconda/lib/python2.7/site-packages/runipy-0.1.0-py2.7.egg',
 '/home/safuser/miniconda/lib/python2.7/site-packages/setuptools-3.6-py2.7.egg',
 '/home/safuser/miniconda/lib/python2.7/site-packages/IPython/extensions',
 '/home/safuser/apps/girder',
 '/home/safuser/apps/girder/clients/python',
 '/home/safuser/apps/girder/plugins',
 '/home/safuser/apps/girder/plugins/romanesco']

In [4]:

    

import celery
import json
import girder
import romanesco


    

In [5]:

    

celeryapp = celery.Celery('romanesco',
    backend='mongodb://localhost/romanesco',
    broker='mongodb://localhost/romanesco')


    

In [31]:

    

analysis = {
    "name" : "simple add",
    "inputs" : [{ "name" : "a", 
}

]
}




async_result = celeryapp.send_task("romanesco.run", [analysis], {
    "inputs": {
        "a": {"format": "rows", "data": [{"aa": 1, "bb": 2}]},
        "b": {"format": "rows", "data": [{"aa": 3, "bb": 4}]}
    },
    "outputs": {
        "c": {"format": "rows", "uri": "mongodb://romanesco/testput"}
    }
})


    

In [32]:

    

async_result.backend


    

    
Out[32]:





<celery.backends.mongodb.MongoBackend at 0x7f3cbc033c50>

In [33]:

    

print async_result.get()


    

    




---------------------------------------------------------------------------
Exception                                 Traceback (most recent call last)
<ipython-input-33-6ea13e4b5b18> in <module>()
----> 1 print async_result.get()

/home/safuser/miniconda/lib/python2.7/site-packages/celery/result.pyc in get(self, timeout, propagate, interval, no_ack, follow_parents)
    167                 interval=interval,
    168                 on_interval=on_interval,
--> 169                 no_ack=no_ack,
    170             )
    171         finally:

/home/safuser/miniconda/lib/python2.7/site-packages/celery/backends/base.pyc in wait_for(self, task_id, timeout, propagate, interval, no_ack, on_interval)
    213                 result = self.get_result(task_id)
    214                 if propagate:
--> 215                     raise result
    216                 return result
    217             if on_interval:

Exception: Input a (Python type <type 'list'>) is not in the expected type (table) and format (rows).

In [9]:

    

async_result.state


    

    
Out[9]:





u'FAILURE'

In [10]:

    

async_result.successful()


    

    
Out[10]:





False

In [11]:

    

romanesco.format.print_conversion_table()[source]


    

    




from,to
string:text,string:json
string:json,string:text
boolean:json,boolean:boolean
boolean:boolean,boolean:json
image:pil,image:png.base64
image:pil,image:png
image:png.base64,image:pil
image:png.base64,image:png
image:png,image:pil
image:png,image:png.base64
tree:nested.json,tree:nexus
tree:nested.json,tree:vtktree
tree:nested.json,tree:r.apetree
tree:nested.json,tree:newick
tree:nested.json,tree:vtktree.serialized
tree:nested.json,tree:nested
tree:nested.json,tree:treestore
tree:nexus,tree:nested.json
tree:nexus,tree:treestore
tree:nexus,tree:r.apetree
tree:nexus,tree:nested
tree:nexus,tree:vtktree.serialized
tree:nexus,tree:newick
tree:nexus,tree:vtktree
tree:vtktree,tree:nested.json
tree:vtktree,tree:nexus
tree:vtktree,tree:treestore
tree:vtktree,tree:r.apetree
tree:vtktree,tree:newick
tree:vtktree,tree:vtktree.serialized
tree:vtktree,tree:nested
tree:r.apetree,tree:nested.json
tree:r.apetree,tree:nexus
tree:r.apetree,tree:treestore
tree:r.apetree,tree:newick
tree:r.apetree,tree:vtktree.serialized
tree:r.apetree,tree:nested
tree:r.apetree,tree:vtktree
tree:nested,tree:nested.json
tree:nested,tree:nexus
tree:nested,tree:vtktree
tree:nested,tree:r.apetree
tree:nested,tree:newick
tree:nested,tree:vtktree.serialized
tree:nested,tree:treestore
tree:vtktree.serialized,tree:nested.json
tree:vtktree.serialized,tree:nexus
tree:vtktree.serialized,tree:vtktree
tree:vtktree.serialized,tree:r.apetree
tree:vtktree.serialized,tree:nested
tree:vtktree.serialized,tree:newick
tree:vtktree.serialized,tree:treestore
tree:newick,tree:nested.json
tree:newick,tree:nexus
tree:newick,tree:vtktree
tree:newick,tree:r.apetree
tree:newick,tree:nested
tree:newick,tree:vtktree.serialized
tree:newick,tree:treestore
number:json,number:number
number:number,number:json
geometry:vtkpolydata,geometry:vtkpolydata.serialized
geometry:vtkpolydata.serialized,geometry:vtkpolydata
r:serialized,r:object
r:object,r:serialized
table:vtktable.serialized,table:rows
table:vtktable.serialized,table:objectlist.bson
table:vtktable.serialized,table:column.names.continuous
table:vtktable.serialized,table:tsv
table:vtktable.serialized,table:r.dataframe
table:vtktable.serialized,table:vtktable
table:vtktable.serialized,table:column.names
table:vtktable.serialized,table:objectlist.json
table:vtktable.serialized,table:column.names.discrete
table:vtktable.serialized,table:csv
table:vtktable.serialized,table:rows.json
table:vtktable.serialized,table:objectlist
table:rows,table:vtktable.serialized
table:rows,table:objectlist.bson
table:rows,table:column.names.continuous
table:rows,table:column.names
table:rows,table:r.dataframe
table:rows,table:vtktable
table:rows,table:tsv
table:rows,table:objectlist.json
table:rows,table:column.names.discrete
table:rows,table:csv
table:rows,table:rows.json
table:rows,table:objectlist
table:objectlist.bson,table:vtktable.serialized
table:objectlist.bson,table:rows
table:objectlist.bson,table:column.names.continuous
table:objectlist.bson,table:tsv
table:objectlist.bson,table:objectlist.json
table:objectlist.bson,table:vtktable
table:objectlist.bson,table:column.names
table:objectlist.bson,table:r.dataframe
table:objectlist.bson,table:column.names.discrete
table:objectlist.bson,table:csv
table:objectlist.bson,table:rows.json
table:objectlist.bson,table:objectlist
table:r.dataframe,table:vtktable.serialized
table:r.dataframe,table:rows
table:r.dataframe,table:column.names.continuous
table:r.dataframe,table:objectlist.bson
table:r.dataframe,table:tsv
table:r.dataframe,table:objectlist.json
table:r.dataframe,table:vtktable
table:r.dataframe,table:column.names
table:r.dataframe,table:column.names.discrete
table:r.dataframe,table:csv
table:r.dataframe,table:rows.json
table:r.dataframe,table:objectlist
table:vtktable,table:vtktable.serialized
table:vtktable,table:rows
table:vtktable,table:objectlist.bson
table:vtktable,table:column.names.continuous
table:vtktable,table:tsv
table:vtktable,table:r.dataframe
table:vtktable,table:column.names
table:vtktable,table:objectlist.json
table:vtktable,table:column.names.discrete
table:vtktable,table:csv
table:vtktable,table:rows.json
table:vtktable,table:objectlist
table:tsv,table:vtktable.serialized
table:tsv,table:rows
table:tsv,table:objectlist.bson
table:tsv,table:column.names.continuous
table:tsv,table:r.dataframe
table:tsv,table:vtktable
table:tsv,table:column.names
table:tsv,table:objectlist.json
table:tsv,table:column.names.discrete
table:tsv,table:csv
table:tsv,table:rows.json
table:tsv,table:objectlist
table:objectlist.json,table:vtktable.serialized
table:objectlist.json,table:rows
table:objectlist.json,table:objectlist.bson
table:objectlist.json,table:column.names.continuous
table:objectlist.json,table:tsv
table:objectlist.json,table:r.dataframe
table:objectlist.json,table:vtktable
table:objectlist.json,table:column.names
table:objectlist.json,table:column.names.discrete
table:objectlist.json,table:csv
table:objectlist.json,table:rows.json
table:objectlist.json,table:objectlist
table:csv,table:vtktable.serialized
table:csv,table:rows
table:csv,table:objectlist.bson
table:csv,table:column.names.continuous
table:csv,table:tsv
table:csv,table:r.dataframe
table:csv,table:vtktable
table:csv,table:column.names
table:csv,table:objectlist.json
table:csv,table:column.names.discrete
table:csv,table:rows.json
table:csv,table:objectlist
table:rows.json,table:vtktable.serialized
table:rows.json,table:rows
table:rows.json,table:objectlist.bson
table:rows.json,table:column.names.continuous
table:rows.json,table:tsv
table:rows.json,table:r.dataframe
table:rows.json,table:vtktable
table:rows.json,table:column.names
table:rows.json,table:objectlist.json
table:rows.json,table:column.names.discrete
table:rows.json,table:csv
table:rows.json,table:objectlist
table:objectlist,table:vtktable.serialized
table:objectlist,table:rows
table:objectlist,table:column.names.continuous
table:objectlist,table:objectlist.bson
table:objectlist,table:tsv
table:objectlist,table:objectlist.json
table:objectlist,table:vtktable
table:objectlist,table:column.names
table:objectlist,table:r.dataframe
table:objectlist,table:column.names.discrete
table:objectlist,table:csv
table:objectlist,table:rows.json






    




---------------------------------------------------------------------------
TypeError                                 Traceback (most recent call last)
<ipython-input-11-7bbc4cdf77d6> in <module>()
----> 1 romanesco.format.print_conversion_table()[source]

TypeError: 'NoneType' object has no attribute '__getitem__'

In [36]:

    

analysis = {
    "name": "append_tables",
    "inputs": [{"name": "a", "type": "table", "format": "rows"}, 
               {"name": "b", "type": "table", "format": "rows"}],
    "outputs": [{"name": "c", "type": "table", "format": "rows"}],
    "script": "c = a + b",
    "mode": "python"
}
import json

romanesco.load(json.dumps(analysis))


    

    




---------------------------------------------------------------------------
IOError                                   Traceback (most recent call last)
<ipython-input-36-58b0ae13ca76> in <module>()
      9 import json
     10 
---> 11 romanesco.load(json.dumps(analysis))

/home/safuser/apps/girder/plugins/romanesco/romanesco/__init__.pyc in load(analysis_file)
     22     """
     23 
---> 24     with open(analysis_file) as f:
     25         analysis = json.load(f)
     26 

IOError: [Errno 2] No such file or directory: '{"inputs": [{"type": "table", "name": "a", "format": "rows"}, {"type": "table", "name": "b", "format": "rows"}], "mode": "python", "script": "c = a + b", "name": "append_tables", "outputs": [{"type": "table", "name": "c", "format": "rows"}]}'