From 7cbb273f652d8f4e2afd3c41b2453c19be288916 Mon Sep 17 00:00:00 2001 From: gola077 Date: Mon, 22 May 2023 17:31:04 +0000 Subject: [PATCH 1/3] test --- w2/server.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/w2/server.py b/w2/server.py index 9ee44a0..67179ce 100644 --- a/w2/server.py +++ b/w2/server.py @@ -42,7 +42,7 @@ async def get() -> Dict: """ ######################################## YOUR CODE HERE ################################################## - + test ######################################## YOUR CODE HERE ################################################## From 2b4f426ec7e4cfd4c622ddc2579a26aff69c41a5 Mon Sep 17 00:00:00 2001 From: gola077 Date: Mon, 22 May 2023 17:33:00 +0000 Subject: [PATCH 2/3] test --- w2/server.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/w2/server.py b/w2/server.py index 67179ce..d1192f3 100644 --- a/w2/server.py +++ b/w2/server.py @@ -42,7 +42,7 @@ async def get() -> Dict: """ ######################################## YOUR CODE HERE ################################################## - test + return {"status": "ok"} ######################################## YOUR CODE HERE ################################################## From 0e99e9087f577887b1d936bbeea1a923bbb2c5e6 Mon Sep 17 00:00:00 2001 From: gola077 Date: Thu, 25 May 2023 18:04:50 +0000 Subject: [PATCH 3/3] week3 project --- w3/main.py | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/w3/main.py b/w3/main.py index 1e53962..b47a886 100644 --- a/w3/main.py +++ b/w3/main.py @@ -144,7 +144,7 @@ def main() -> List[Dict]: """ st = time.time() - n_processes = 3 # you may modify this number - check out multiprocessing.cpu_count() as well + n_processes = 6 # you may modify this number - check out multiprocessing.cpu_count() as well parser = argparse.ArgumentParser(description="Choose from one of these : [tst|sml|bg]") parser.add_argument('--type', @@ -164,14 +164,27 @@ def main() -> List[Dict]: batches = batch_files(file_paths=file_paths, n_processes=n_processes) ######################################## YOUR CODE HERE ################################################## + with multiprocessing.Pool(processes=n_processes) as pool: + revenue_data = pool.starmap(run, [(batch, n_process) for n_process, batch in enumerate(batches)]) + revenue_data = flatten(lst=revenue_data) + pool.close() + pool.join() ######################################## YOUR CODE HERE ################################################## en = time.time() print("Overall time taken : {}".format(en-st)) # should return revenue data - return [{}] + for yearly_data in revenue_data: + with open(os.path.join(output_save_folder, f'{yearly_data["file_name"]}.json'), 'w') as f: + f.write(json.dumps(yearly_data)) + + plot_sales_data(yearly_revenue=yearly_data['revenue_per_region'], year=yearly_data["file_name"], + plot_save_path=os.path.join(output_save_folder, f'{yearly_data["file_name"]}.png')) + + return revenue_data + # return [{}] if __name__ == '__main__':