Skip to content

Commit 23223f7

Browse files
committed
replace newline characters in projects
1 parent ce67205 commit 23223f7

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

mapswipe_workers/mapswipe_workers/generate_stats/overall_stats.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,15 +45,17 @@ def get_project_static_info(filename: str) -> pd.DataFrame:
4545
"""
4646

4747
pg_db = auth.postgresDB()
48+
49+
# make sure to replace newline characters here
4850
sql_query = """
4951
COPY (
5052
SELECT
5153
project_id
52-
,name
53-
,project_details
54-
,look_for
54+
,regexp_replace(name, E'[\\n\\r]+', ' ', 'g' ) as name
55+
,regexp_replace(project_details, E'[\\n\\r]+', ' ', 'g' ) as project_details
56+
,regexp_replace(look_for, E'[\\n\\r]+', ' ', 'g' ) as look_for
5557
,project_type
56-
,status
58+
,regexp_replace(status, E'[\\n\\r]+', ' ', 'g' ) as status
5759
,ST_Area(geom::geography)/1000000 as area_sqkm
5860
,ST_AsText(geom) as geom
5961
,ST_AsText(ST_Centroid(geom)) as centroid
@@ -67,6 +69,7 @@ def get_project_static_info(filename: str) -> pd.DataFrame:
6769
logger.info("got projects from postgres.")
6870

6971
df = pd.read_csv(filename)
72+
7073
return df
7174

7275

@@ -116,7 +119,7 @@ def save_projects(filename: str, df: pd.DataFrame, df_dynamic: pd.DataFrame) ->
116119
projects_df = df.merge(
117120
df_dynamic, left_on="project_id", right_on="project_id", how="left"
118121
)
119-
projects_df.to_csv(filename, index_label="idx")
122+
projects_df.to_csv(filename, index_label="idx", line_terminator='\n')
120123
logger.info(f"saved projects: {filename}")
121124
geojson_functions.csv_to_geojson(filename, "geom")
122125
geojson_functions.csv_to_geojson(filename, "centroid")

0 commit comments

Comments
 (0)