Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- day_date cabinet_name ... epoch_time sum_pwr
- 0 2017-01-01 US.PRZ.03.01.2200.03.001 ... 1483228800 2.3368
- 1 2017-01-01 US.PRZ.03.01.2200.03.002 ... 1483228800 4.6188
- 2 2017-01-01 US.PRZ.03.01.2200.03.003 ... 1483228800 2.2688
- 3 2017-01-01 US.PRZ.03.01.2200.03.004 ... 1483228800 2.1966
- 4 2017-01-01 US.PRZ.03.01.2200.03.005 ... 1483228800 2.2108
- [5 rows x 5 columns]
- [#################################### ] | 92% Completed | 0.4s
- Exception in thread Thread-2:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python@2/2.7.15/Frameworks/Python.framework/Versions/2.7/lib/python2.7/threading.py", line 801, in __bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python@2/2.7.15/Frameworks/Python.framework/Versions/2.7/lib/python2.7/threading.py", line 754, in run
- self.__target(*self.__args, **self.__kwargs)
- File "amrith_code.py", line 103, in do_work
- df6 = df6.append(process_file(df).compute())
- File "amrith_code.py", line 78, in process_file
- print (df3.head())
- File "/usr/local/lib/python2.7/site-packages/dask/dataframe/core.py", line 908, in head
- result = result.compute()
- File "/usr/local/lib/python2.7/site-packages/dask/base.py", line 156, in compute
- (result,) = compute(self, traverse=False, **kwargs)
- File "/usr/local/lib/python2.7/site-packages/dask/base.py", line 400, in compute
- results = schedule(dsk, keys, **kwargs)
- File "/usr/local/lib/python2.7/site-packages/dask/threaded.py", line 75, in get
- pack_exception=pack_exception, **kwargs)
- File "/usr/local/lib/python2.7/site-packages/dask/local.py", line 521, in get_async
- raise_exception(exc, tb)
- File "/usr/local/lib/python2.7/site-packages/dask/local.py", line 290, in execute_task
- result = _execute_task(task, data)
- File "/usr/local/lib/python2.7/site-packages/dask/local.py", line 271, in _execute_task
- return func(*args2)
- File "/usr/local/lib/python2.7/site-packages/dask/dataframe/core.py", line 3558, in apply_and_enforce
- raise ValueError("The columns in the computed data do not match"
- ValueError: The columns in the computed data do not match the columns in the provided metadata
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement