intake: FTBFS: dh_auto_test: error: pybuild --test --test-pytest -i python{version} -p "3.12 3.11" returned exit code 13
| Affects | Status | Importance | Assigned to | Milestone | |
|---|---|---|---|---|---|
| intake (Debian) |
New
|
Unknown
|
|||
| intake (Ubuntu) |
New
|
Undecided
|
Unassigned | ||
Bug Description
Imported from Debian bug http://
Source: intake
Version: 0.6.6-3
Severity: serious
Justification: FTBFS
Tags: trixie sid ftbfs
User: <email address hidden>
Usertags: ftbfs-20240224 ftbfs-trixie
Hi,
During a rebuild of all packages in sid, your package failed to build
on amd64.
Relevant part (hopefully):
> make[1]: Entering directory '/<<PKGBUILDDIR>>'
> dh_install
> # For some reason, not all data is movable via install or dh_install, so
> # just force copy (and overwrite if needed) for pytest to actually work
> set -e \
> ; for py in `py3versions -sv` \
> ; do builddir=
> ; cp -a intake/source/tests ${builddir}
> ; cp -a intake/
> ; cp -a intake/
> ; done
> PYBUILD_
> PYBUILD_
> dh_auto_test --buildsystem=
> I: pybuild base:305: cd /<<PKGBUILDDIR>
> =======
> platform linux -- Python 3.12.2, pytest-7.4.4, pluggy-1.4.0
> rootdir: /<<PKGBUILDDIR>>
> collected 427 items / 10 skipped
>
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> .......
> intake/
> intake/
> intake/
> intake/
> ... [ 43%]
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
> intake/
>
> =======
> _______
>
> catalog_cache = <Intake catalog: catalog_caching>
>
> def test_load_
> cat = catalog_
> cache = cat.cache[0]
>
> cache_paths = cache.load(
> > cache_path = cache_paths[-1]
> E TypeError: 'NoneType' object is not subscriptable
>
> intake/
> _______
>
> args = ('/<<PKGBUILDDI
> kwargs = {'storage_options': None}
> func = <function make_reader.
>
> @wraps(fn)
> def wrapper(*args, **kwargs):
> func = getattr(self, dispatch_name)
> try:
> > return func(*args, **kwargs)
>
> /usr/lib/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> /usr/lib/
> return read_pandas(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> reader = <function read_csv at 0x7ff50f5aaf20>
> urlpath = '/<<PKGBUILDDIR
> blocksize = 'default', lineterminator = '\n', compression = 'infer'
> sample = 256000, sample_rows = 10, enforce = False, assume_missing = False
> storage_options = None, include_path_column = False, kwargs = {}
> reader_name = 'read_csv', kw = 'chunksize', lastskiprow = 0, firstrow = 0
> path_converter = None, paths = []
>
> def read_pandas(
> reader,
> urlpath,
> blocksize=
> lineterminator=
> compression=
> sample=256000,
> sample_rows=10,
> enforce=False,
> assume_
> storage_
> include_
> **kwargs,
> ):
> reader_name = reader.__name__
> if lineterminator is not None and len(lineterminator) == 1:
> kwargs[
> else:
> lineterminator = "\n"
> if include_path_column and isinstance(
> include_path_column = "path"
> if "index" in kwargs or (
> "index_col" in kwargs and kwargs.
> ):
> raise ValueError(
> "Keywords 'index' and 'index_col' not supported, except for "
> "'index_col=False'. Use dd.{reader_
> )
> for kw in ["iterator", "chunksize"]:
> if kw in kwargs:
> raise ValueError(f"{kw} not supported for dd.{reader_name}")
> if kwargs.get("nrows", None):
> raise ValueError(
> "The 'nrows' keyword is not supported by "
> "`dd.{0}`. To achieve the same behavior, it's "
> "recommended to use `dd.{0}(...)."
> "head(n=
> )
> if isinstance(
> lastskiprow = firstrow = kwargs.
> elif kwargs.
> lastskiprow = firstrow = 0
> else:
> # When skiprows is a list, we expect more than max(skiprows) to
> # be included in the sample. This means that [0,2] will work well,
> # but [0, 440] might not work.
> skiprows = set(kwargs.
> lastskiprow = max(skiprows)
> # find the firstrow that is not skipped, for use as header
> firstrow = min(set(
> if isinstance(
> raise TypeError(f"List of header rows not supported for dd.{reader_name}")
> if isinstance(
> path_converter = kwargs.
> else:
> path_converter = None
>
> # If compression is "infer", inspect the (first) path suffix and
> # set the proper compression option if the suffix is recongnized.
> if compression == "infer":
> # Translate the input urlpath to a simple path list
> paths = get_fs_
> 2
> ]
>
> # Check for at least one valid path
> if len(paths) == 0:
> > raise OSError(f"{urlpath} resolved to no files")
> E OSError: /<<PKGBUILDDIR>
>
> /usr/lib/
>
> The above exception was the direct cause of the following exception:
>
> catalog1 = <Intake catalog: name_in_cat>
>
> def test_nested(
> assert 'nested' in catalog1
> assert 'entry1' in catalog1.
> > assert catalog1.
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> self._get_schema()
> intake/
> self._open_
> intake/
> self._dataframe = dask.dataframe.
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> args = ('/<<PKGBUILDDI
> kwargs = {'storage_options': None}
> func = <function make_reader.
>
> @wraps(fn)
> def wrapper(*args, **kwargs):
> func = getattr(self, dispatch_name)
> try:
> return func(*args, **kwargs)
> except Exception as e:
> > raise type(e)(
> f"An error occurred while calling the {funcname(func)} "
> f"method registered to the {self.backend} backend.\n"
> f"Original Message: {e}"
> ) from e
> E OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> E Original Message: /<<PKGBUILDDIR>
>
> /usr/lib/
> _______
>
> intake_server = 'intake:
>
> def test_info_
> catalog = open_catalog(
>
> assert_
> 'entry1_part', 'remote_env',
> 'local_env', 'text', 'arr', 'datetime'])
>
> > info = catalog[
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> 2024-02-24 22:52:23,664 - intake - INFO - __main_
> 2024-02-24 22:52:23,664 - intake - INFO - __main_
> 2024-02-24 22:52:23,970 - intake - INFO - __main_
> 2024-02-24 22:52:23,970 - intake - INFO - __main_
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 159.88ms
> _______
>
> intake_server = 'intake:
>
> def test_remote_
> from intake.
> catalog = open_catalog(
> > s0 = catalog.entry1()
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> return self[item] # triggers reload_on_change
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 2.71ms
> _______
>
> intake_server = 'intake:
>
> def test_remote_
> catalog = open_catalog(
>
> > d = catalog['entry1']
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 2.43ms
> _______
>
> intake_server = 'intake:
>
> def test_read(
> catalog = open_catalog(
>
> > d = catalog['entry1']
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 2.32ms
> _______
>
> intake_server = 'intake:
>
> def test_read_
> catalog = open_catalog(
>
> > d = catalog.entry1
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> return self[item] # triggers reload_on_change
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 2.42ms
> _______
>
> intake_server = 'intake:
>
> def test_read_
> catalog = open_catalog(
>
> > d = catalog.entry1
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> return self[item] # triggers reload_on_change
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> name=entry,
> parameters=
> available_
> req = requests.
> data=msgpack.
> **http_args)
> if req.ok:
> response = msgpack.
>
> if 'plugin' in response:
> pl = response['plugin']
> pl = [pl] if isinstance(pl, str) else pl
> # Direct access
> for p in pl:
> if p in plugin_registry:
> source = plugin_
> proxy = False
> break
> else:
> proxy = True
> else:
> proxy = True
> if proxy:
> response.
> response.
> if container == 'catalog':
> response.
> 'getenv': getenv,
> 'getshell': getshell,
> 'page_size': page_size,
> 'persist_mode': persist_mode
> # TODO ttl?
> # TODO storage_options?
> })
> source = container_
> source.description = description
> return source
> else:
> > raise Exception('Server error: %d, %s' % (req.status_code, req.reason))
> E Exception: Server error: 400, An error occurred while calling the read_csv method registered to the pandas backend. Original Message: /<<PKGBUILDDIR>
>
> intake/
> -------
> Traceback (most recent call last):
> File "/usr/lib/
> return func(*args, **kwargs)
> ^^^^^^^
> File "/usr/lib/
> return read_pandas(
> ^^^^^^^^^^^^
> File "/usr/lib/
> raise OSError(f"{urlpath} resolved to no files")
> OSError: /<<PKGBUILDDIR>
>
> The above exception was the direct cause of the following exception:
>
> Traceback (most recent call last):
> File "/<<PKGBUILDDIR
> source.discover()
> File "/<<PKGBUILDDIR
> self._load_
> File "/<<PKGBUILDDIR
> self._schema = self._get_schema()
> ^^^^^^^^^^^^^^^^^^
> File "/<<PKGBUILDDIR
> self._open_
> File "/<<PKGBUILDDIR
> self._dataframe = dask.dataframe.
> ^^^^^^^
> File "/usr/lib/
> raise type(e)(
> OSError: An error occurred while calling the read_csv method registered to the pandas backend.
> Original Message: /<<PKGBUILDDIR>
> 400 POST /v1/source (127.0.0.1): Discover failed
> 400 POST /v1/source (127.0.0.1) 2.44ms
> _______
>
> intake_server = 'intake:
>
> def test_close(
> catalog = open_catalog(
>
> > d = catalog.entry1
>
> intake/
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> intake/
> return self[item] # triggers reload_on_change
> intake/
> s = self._get_
> intake/
> return f(self, *args, **kwargs)
> intake/
> return entry()
> intake/
> s = self.get(**kwargs)
> intake/
> return open_remote(
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
>
> url = 'http://
> user_parameters = {}, description = 'entry1 full', http_args = {'headers': {}}
> page_size = None, persist_mode = 'default'
> auth = <intake.
> getshell = True
>
> def open_remote(url, entry, container, user_parameters, description, http_args,
> page_size=None, persist_mode=None, auth=None, getenv=None, getshell=None):
> """Create either local direct data source or remote streamed source"""
> from intake.container import container_map
> import msgpack
> import requests
> from requests.compat import urljoin
>
> if url.startswith(
> url = url[len(
> payload = dict(action='open',
> [...]
| tags: | added: update-excuse |
| Changed in intake (Debian): | |
| importance: | Undecided → Unknown |
