Skip to content

Chris feedback #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions multiprocessing_talk/__main__.py
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
from ismain import is_main
from multiprocessing_talk import main_process, main_pool
from pathlib import Path

from balsa import Balsa
from ismain import is_main

from multiprocessing_talk import application_name, author
from multiprocessing_talk import application_name, author, main_process, main_pool


def main():
balsa = Balsa(
application_name,
author,
log_directory="log",
log_directory=Path("multiprocessing_talk", "log"),
delete_existing_log_files=True,
verbose=False, # turn verbose on/off to show logging into stdout
)
Expand Down
4 changes: 3 additions & 1 deletion multiprocessing_talk/pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,9 @@ def main_pool(balsa: Balsa):

# run the workers using .apply_async()
e_process = pool.apply_async(calculate_e, args=(e_exit_event, balsa_config))
dir_path = Path(Path(".").absolute().anchor, "Program Files", "Python310")
# replace hardcoded path so code works when people clone repo
# dir_path = Path(Path(".").absolute().anchor, "Program Files", "Python310")
dir_path = Path.cwd() / "venv"
dir_info_result = pool.apply_async(
get_dir_info,
args=(dir_path, balsa_config),
Expand Down
8 changes: 6 additions & 2 deletions multiprocessing_talk/process.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,10 @@ def main_process(balsa: Balsa):
log.info(f"starting {application_name}")
e_process = CalculateE(balsa_config) # pass in log config
e_process.start() # calculates e
dir_info_process = GetDirInfo(Path(Path(".").absolute().anchor, "Program Files", "Python310"), balsa_config)
# replace hardcoded path so code works when people clone repo
# dir_info_process = GetDirInfo(Path(Path(".").absolute().anchor, "Program Files", "Python310"), balsa_config)
dir_info_process = GetDirInfo(
Path.cwd(), balsa_config)
dir_info_process.start()

# request exit from "e" process and wait for dir info
Expand All @@ -92,7 +95,8 @@ def main_process(balsa: Balsa):
print(dir_info_process.get())
e_process.exit_event.set()
e_value, e_iterations, e_duration = e_process.get()
print(f"calculated {e_value=} for {e_iterations:,} iterations in {e_duration} seconds")
print(f"\n"
f"calculated {e_value=} for {e_iterations:,} iterations in {e_duration} seconds")

print(f"total time: {time.time() - start} seconds")
print()