greenplum-db / greenplumpython Goto Github PK

$ python3
>>> import pandas as pd
>>> import greenplumpython as gppy
>>> connection = gppy.GPConnection()
>>> conn = connection.connect( 'localhost', 6000, 'testdb', 'gpadmin', '')
>>> testdb_inst = gppy.GPDatabase(conn)
>>> dfwrap_table1 = testdb_inst.get_table( 'table1', 'public')
>>> otbl_cols = list()
>>> otuple = ('c1', 'int')
>>> otbl_cols.append(otuple)
>>> otbl_meta = gppy.GPTableMetadata(None, otbl_cols, None)
>>> # apply function
... def input_py_func(row_element, extra_args):
...     return row_element + extra_args
... 
>>> df = gppy.gpApply(dfwrap_table1, input_py_func, testdb_inst, otbl_meta, 'plc_python_shared')
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/gpadmin/GreenplumPython/greenplumpython/core/gpapply.py", line 39, in gpApply
    s = inspect.getsource(py_func)
  File "/usr/lib64/python3.6/inspect.py", line 973, in getsource
    lines, lnum = getsourcelines(object)
  File "/usr/lib64/python3.6/inspect.py", line 955, in getsourcelines
    lines, lnum = findsource(object)
  File "/usr/lib64/python3.6/inspect.py", line 786, in findsource
    raise OSError('could not get source code')
OSError: could not get source code

BACKEND SESSION PID:  [RealDictRow([('pg_backend_pid', 11777)])]
DB OBJECT ID:  140420733129040
CREATE FUNCTION "pg_temp"."func_f8e86dfce7934fb98e098e9cc0eb75d6" (date "text") RETURNS "text" AS $$

BACKEND SESSION PID:  [RealDictRow([('pg_backend_pid', 11780)])]
DB OBJECT ID:  140420733129040
function pg_temp.func_f8e86dfce7934fb98e098e9cc0eb75d6(text) does not exist