Skip to content

Commit 1dafb46

Browse files
committed
Bumping version to 0.0.7
1 parent 79b6c3a commit 1dafb46

File tree

4 files changed

+5
-11
lines changed

4 files changed

+5
-11
lines changed

awswrangler/__version__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
__title__ = "awswrangler"
22
__description__ = "Utility belt to handle data on AWS."
3-
__version__ = "0.0.6"
3+
__version__ = "0.0.7"
44
__license__ = "Apache License 2.0"

awswrangler/pandas.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -646,8 +646,7 @@ def to_s3(self,
646646
procs_cpu_bound=procs_cpu_bound,
647647
procs_io_bound=procs_io_bound,
648648
cast_columns=cast_columns,
649-
extra_args=extra_args,
650-
inplace=inplace)
649+
extra_args=extra_args)
651650
if database:
652651
self._session.glue.metadata_to_glue(dataframe=dataframe,
653652
path=path,
@@ -674,8 +673,7 @@ def data_to_s3(self,
674673
procs_cpu_bound=None,
675674
procs_io_bound=None,
676675
cast_columns=None,
677-
extra_args=None,
678-
inplace=True):
676+
extra_args=None):
679677
if not procs_cpu_bound:
680678
procs_cpu_bound = self._session.procs_cpu_bound
681679
if not procs_io_bound:
@@ -717,8 +715,7 @@ def data_to_s3(self,
717715
session_primitives=self._session.primitives,
718716
file_format=file_format,
719717
cast_columns=cast_columns,
720-
extra_args=extra_args,
721-
isolated_dataframe=inplace)
718+
extra_args=extra_args)
722719
if mode == "overwrite_partitions" and partition_cols:
723720
if procs_io_bound > procs_cpu_bound:
724721
num_procs = floor(
@@ -890,7 +887,7 @@ def write_parquet_dataframe(dataframe, path, preserve_index, compression,
890887
dtypes = copy.deepcopy(dataframe.dtypes.to_dict())
891888
for name, dtype in dtypes.items():
892889
if str(dtype) == "Int64":
893-
dataframe[name] = dataframe[name].astype("float64")
890+
dataframe.loc[:, name] = dataframe[name].astype("float64")
894891
casted_in_pandas.append(name)
895892
cast_columns[name] = "bigint"
896893
logger.debug(f"Casting column {name} Int64 to float64")

testing/test_awswrangler/test_cloudwatchlogs.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import logging
22
from datetime import datetime
3-
from time import sleep
43

54
import pytest
65
import boto3
@@ -64,7 +63,6 @@ def logstream(cloudformation_outputs, loggroup):
6463
if token:
6564
args["sequenceToken"] = token
6665
client.put_log_events(**args)
67-
sleep(300)
6866
yield logstream
6967

7068

testing/test_awswrangler/test_pandas.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,6 @@ def logstream(cloudformation_outputs, loggroup):
9999
if token:
100100
args["sequenceToken"] = token
101101
client.put_log_events(**args)
102-
sleep(300)
103102
yield logstream
104103

105104

0 commit comments

Comments
 (0)