issue-814 fix formatting for python files

Author: morozov-av

bases/rsptx/admin_server_api/routers/instructor.py

@@ -1257,7 +1257,7 @@ async def post_create_course_page(
         # if invoice is true then we need to create an invoice for the course
         if invoice == "true":
             res = await create_invoice_request(
-                user.username, projectname, 0.0,  user.email
+                user.username, projectname, 0.0, user.email
             )
         # Copy attributes from base course
         bc = await fetch_course(coursetype)

bases/rsptx/admin_server_api/routers/lti1p3.py

@@ -446,7 +446,10 @@ async def launch(request: Request):
                 status_code=400, detail=f"Assignment {lineitem_assign_id} not found"
             )
 
-        if not is_assignment_visible_to_students(rs_assign) and not message_launch.check_teacher_access():
+        if (
+            not is_assignment_visible_to_students(rs_assign)
+            and not message_launch.check_teacher_access()
+        ):
             raise HTTPException(
                 status_code=400,
                 detail=f"Assignment {rs_assign.name} is not open for students",

bases/rsptx/assignment_server_api/routers/instructor.py

@@ -71,7 +71,11 @@
     delete_datafile,
 )
 from rsptx.db.crud.question import validate_question_name_unique, copy_question
-from rsptx.db.crud.assignment import add_assignment_question, delete_assignment, is_assignment_visible_to_students
+from rsptx.db.crud.assignment import (
+    add_assignment_question,
+    delete_assignment,
+    is_assignment_visible_to_students,
+)
 from rsptx.auth.session import auth_manager, is_instructor
 from rsptx.templates import template_folder
 from rsptx.configuration import settings
@@ -1218,9 +1222,9 @@ async def do_download_assignment(
         csv_buffer,
         media_type="text/csv",
     )
-    response.headers["Content-Disposition"] = (
-        f"attachment; filename=assignment_{assignment_id}.csv"
-    )
+    response.headers[
+        "Content-Disposition"
+    ] = f"attachment; filename=assignment_{assignment_id}.csv"
 
     return response
 

bases/rsptx/assignment_server_api/routers/student.py

@@ -107,9 +107,12 @@ async def get_assignments(
         # Also include assignments the student has deadline exceptions for,
         # even if they are not currently visible via scheduled dates
         if assignment_ids:
-            all_assignments = await fetch_assignments(course.course_name, fetch_all=True)
+            all_assignments = await fetch_assignments(
+                course.course_name, fetch_all=True
+            )
             exception_assignments = [
-                a for a in all_assignments
+                a
+                for a in all_assignments
                 if a.id in assignment_ids and not is_assignment_visible_to_students(a)
             ]
             assignments = list(assignments) + exception_assignments
@@ -121,15 +124,19 @@ def sort_key(assignment):
         deadline = assignment.duedate
         if timezoneoffset:
             deadline = deadline + datetime.timedelta(hours=float(timezoneoffset))
-            return (deadline < canonical_utcnow(), abs((deadline - canonical_utcnow()).total_seconds()))
+            return (
+                deadline < canonical_utcnow(),
+                abs((deadline - canonical_utcnow()).total_seconds()),
+            )
         else:
-            return (assignment.duedate < canonical_utcnow(), abs((assignment.duedate - canonical_utcnow()).total_seconds()))    
+            return (
+                assignment.duedate < canonical_utcnow(),
+                abs((assignment.duedate - canonical_utcnow()).total_seconds()),
+            )
 
     # Sort assignments: upcoming assignments first (closest to current date), past due assignments last
     now = canonical_utcnow()
-    assignments.sort(
-        key=sort_key
-    )
+    assignments.sort(key=sort_key)
     stats_list = await fetch_all_assignment_stats(course.course_name, user.id)
     stats = {}
     for s in stats_list:

bases/rsptx/book_server_api/routers/course.py

@@ -101,9 +101,12 @@ async def index(
         # Also include assignments the student has deadline exceptions for,
         # even if they are not currently visible via scheduled dates
         if assignment_ids:
-            all_assignments = await fetch_assignments(course.course_name, fetch_all=True)
+            all_assignments = await fetch_assignments(
+                course.course_name, fetch_all=True
+            )
             exception_assignments = [
-                a for a in all_assignments
+                a
+                for a in all_assignments
                 if a.id in assignment_ids and not is_assignment_visible_to_students(a)
             ]
             assignments = list(assignments) + exception_assignments
@@ -127,9 +130,7 @@ def sort_key(assignment):
             )
 
     now = canonical_utcnow()
-    assignments.sort(
-        key=sort_key
-    )
+    assignments.sort(key=sort_key)
 
     stats_list = await fetch_all_assignment_stats(course_name, user.id)
     stats = {}

bases/rsptx/rsmanage/core.py

@@ -312,7 +312,9 @@ async def addcourse(
         basecourse = click.prompt("Base Course: ")
     bookrec = await fetch_library_book(basecourse)
     if not bookrec:
-        click.echo(f"{basecourse} Not Found: Please add the book first using `addbookauthor")
+        click.echo(
+            f"{basecourse} Not Found: Please add the book first using `addbookauthor"
+        )
         exit(1)
     if bookrec and bookrec.build_system is None:
         click.echo(
@@ -955,7 +957,9 @@ def grade(config, course, pset, enforce):
 )
 @click.option("--sample_size", help="Number of courses to sample", default=0)
 @click.option("--course_list", help="List of courses to sample", default=None)
-@click.option("--preserve_user_ids", is_flag=True, help="Preserve user ids in the datashop export")
+@click.option(
+    "--preserve_user_ids", is_flag=True, help="Preserve user ids in the datashop export"
+)
 @pass_config
 async def datashop(config, basecourse, sample_size, course_list, preserve_user_ids):
     """Export the course data to the datashop format"""

components/rsptx/build_tools/build.py

@@ -431,9 +431,9 @@ def wheel(config):
 
                             res = subprocess.run(lock_opts, capture_output=True)
                             if res.returncode != 0:
-                                status[proj] = (
-                                    f"[red]Fail[/red] probable dependency conflict see {projdir}/build.log"
-                                )
+                                status[
+                                    proj
+                                ] = f"[red]Fail[/red] probable dependency conflict see {projdir}/build.log"
                                 lt.update(generate_wheel_table(status))
                                 if config.verbose:
                                     console.print(
@@ -894,7 +894,8 @@ def dev(ctx, config):
     ctx.invoke(image)
     ctx.invoke(restart)
 
-# This command should be used when you pull new code from github and want to rebuild and make 
+
+# This command should be used when you pull new code from github and want to rebuild and make
 # sure you are using the latest database schema.  Many people forget to run migrations
 # after pulling new code.
 @cli.command()

components/rsptx/build_tools/core.py

@@ -191,7 +191,7 @@ def _build_ptx_book(config, gen, manifest, course, click=click, target="runeston
 
         if rs.output_dir_abspath().exists():
             shutil.rmtree(rs.output_dir_abspath())
-        
+
         click.echo("Building the book")
         if gen:
             click.echo("Generating assets")
@@ -341,7 +341,7 @@ def check_project_ptx(click=click, course=None, target="runestone"):
     tgt.output_dir = Path(docid)
 
     tgt.stringparams.update({"host-platform": "runestone"})
-    
+
     return tgt
 
 
@@ -705,7 +705,10 @@ def _process_single_chapter(sess, db_context, chapter, chap_num, course_name):
     res = sess.execute(ins)
     return res.inserted_primary_key[0]
 
+
 import pdb
+
+
 def _process_subchapters(sess, db_context, chapter, chapid, course_name):
     """Process all subchapters for a given chapter."""
     subchap = 0
@@ -721,8 +724,10 @@ def _process_subchapters(sess, db_context, chapter, chapid, course_name):
         # at this point (7/28/2025) the only reason for a subsubchapter
         # is to have a timed assignment, so we can skip the rest of the
         # find all divs with a class of timedAssessment
-        #pdb.set_trace()
-        for timed_assessment_div in subchapter.findall(".//div[@class='timedAssessment']"):
+        # pdb.set_trace()
+        for timed_assessment_div in subchapter.findall(
+            ".//div[@class='timedAssessment']"
+        ):
             _process_single_timed_assignment(
                 sess,
                 db_context,

components/rsptx/db/crud/assignment.py

@@ -267,7 +267,7 @@ async def fetch_assignments(
                 Assignment.visible_on.isnot(None),
                 Assignment.hidden_on.isnot(None),
                 Assignment.visible_on <= now,
-                Assignment.hidden_on > now
+                Assignment.hidden_on > now,
             ),
             # Case 2: "Visible on" mode (visible once visible_on passes)
             and_(
@@ -282,8 +282,8 @@ async def fetch_assignments(
                 # visible_on check
                 or_(Assignment.visible_on.is_(None), Assignment.visible_on <= now),
                 # hidden_on check
-                or_(Assignment.hidden_on.is_(None), Assignment.hidden_on > now)
-            )
+                or_(Assignment.hidden_on.is_(None), Assignment.hidden_on > now),
+            ),
         )
     else:
         vclause = True

components/rsptx/db/crud/rsfiles.py

@@ -9,7 +9,9 @@
 
 # We need a synchronous version of this function for use in manifest_data_to_db
 # if/when process_manifest moves to being async we could remove this
-def update_source_code_sync(acid: str, filename: str, course_id: str, main_code: str, owner: str = None):
+def update_source_code_sync(
+    acid: str, filename: str, course_id: str, main_code: str, owner: str = None
+):
     """
     Update the source code for a given acid or filename
     """
@@ -40,7 +42,9 @@ def update_source_code_sync(acid: str, filename: str, course_id: str, main_code:
         session.commit()
 
 
-async def update_source_code(acid: str, filename: str, course_id: str, main_code: str, owner: str = None):
+async def update_source_code(
+    acid: str, filename: str, course_id: str, main_code: str, owner: str = None
+):
     """
     Update the source code for a given acid or filename
     """
@@ -253,6 +257,3 @@ async def delete_datafile(acid: str, course_id: str) -> bool:
         await session.delete(source_code_obj)
         await session.commit()
         return True
-
-
-