B ÛT•\’ã@sLddlmZmZmZddlmZddlmZGdd„deeƒZ e ej d<dS) é)Úprint_functionÚdivisionÚabsolute_import)Ú S3FileSystemé)ÚcorecsBeZdZdZd ‡fdd„ Zdd„Zdd„Zd d „Zd d „Z‡Z S)ÚDaskS3FileSystemú/Nc  sn|dk r|dk rtdƒ‚|}|dk r,||d<|dk rH|dk rDtdƒ‚|}|dk rX||d<tt|ƒjf|ŽdS)Nz“S3 storage options got secrets argument collision. Please, use either `key` storage option or password field in URLpath, not both options together.Úkeyz–S3 storage options got secrets argument collision. Please, use either `secret` storage option or password field in URLpath, not both options together.Úsecret)ÚKeyErrorÚsuperrÚ__init__) Úselfr Zusernamer ZpasswordÚpathZhostÚs3Úkwargs)Ú __class__©ú,lib/python3.7/site-packages/dask/bytes/s3.pyr szDaskS3FileSystem.__init__cCsdS)Nr)rrrrrÚmkdirs"szDaskS3FileSystem.mkdirscCs| |¡dS)NZETag)Úinfo)rrrrrÚukey%szDaskS3FileSystem.ukeycCs| |¡dS)NZSize)r)rrrrrÚsize(szDaskS3FileSystem.sizecCsddl}|j |¡S)z#Get an equivalent pyarrow fileystemrN)ZpyarrowZ filesystemZ S3FSWrapper)rZparrrÚ_get_pyarrow_filesystem+sz(DaskS3FileSystem._get_pyarrow_filesystem)NNNNNNN) Ú__name__Ú __module__Ú __qualname__ÚseprrrrrÚ __classcell__rr)rrrsrrN) Z __future__rrrZs3fsrÚrÚobjectrZ _filesystemsrrrrÚs  )