Merge ~fourdollars/pc-enablement/+git/oem-scripts:master into ~oem-solutions-engineers/pc-enablement/+git/oem-scripts:master

[Shih-Yuan Lee]

There is no functional change.
It is just to refactor the Python checking by flake8 and black.

[Bin Li (binli)]

LGTM.

review: Approve

[Shih-Yuan Lee (fourdollars)]

[BOT]
$ cat oem-scripts-0.98-633af21-in-docker-focal-summary.log
autopkgtest-collect-credentials PASS
autopkgtest-oem-scripts-auto PASS
pkg-somerville-meta PASS
pkg-stella-meta PASS
pkg-sutton-meta PASS
bug-bind PASS
get-private-ppa PASS
jq-lp PASS
launchpad-api PASS
lp-bug PASS
oem-meta-packages PASS
pkg-list PASS
review-merge-proposal PASS
run-autopkgtest PASS
setup-apt-dir PASS
mir-bug SKIP exit status 77 and marked as skippable
git-url-insteadof-setting PASS
recovery-from-iso.sh PASS
mir-bug-verification PASS
https://paste.ubuntu.com/p/g3wxnW9kXF/ oem-scripts-0.98-633af21-in-docker-focal-complete.log

diff --git a/bug-bind.py b/bug-bind.py
index 16056b6..60a9db0 100755
--- a/bug-bind.py
+++ b/bug-bind.py
@@ -9,18 +9,19 @@ import re
 import lazr.restfulclient.resource
 from oem_scripts.LaunchpadLogin import LaunchpadLogin
 
-HWE_PUBLIC_PROJECT = 'hwe-next'
-OEM_PUBLIC_PROJECT = 'oem-priority'
+HWE_PUBLIC_PROJECT = "hwe-next"
+OEM_PUBLIC_PROJECT = "oem-priority"
 
 lp = None
-log = logging.getLogger('bug-bind-logger')
+log = logging.getLogger("bug-bind-logger")
 log.setLevel(logging.DEBUG)
-logging.basicConfig(format='%(levelname)s %(asctime)s - %(message)s',
-                    datefmt='%m/%d/%Y %I:%M:%S %p')
+logging.basicConfig(
+    format="%(levelname)s %(asctime)s - %(message)s", datefmt="%m/%d/%Y %I:%M:%S %p"
+)
 
 
 def link_bugs(public_bugnum, privates, ihv):
-    assert(public_bugnum.isdigit())
+    assert public_bugnum.isdigit()
     login = LaunchpadLogin()
     lp = login.lp
     pub_bug = lp.bugs[public_bugnum]
@@ -29,7 +30,7 @@ def link_bugs(public_bugnum, privates, ihv):
 
     # Add X-HWE-Bug: tag to description.
     for priv in privates:
-        assert(priv.isdigit())
+        assert priv.isdigit()
         bug = lp.bugs[priv]
 
         if re.search(tag, bug.description) is None:
@@ -41,30 +42,35 @@ def link_bugs(public_bugnum, privates, ihv):
 
         if ihv == "hwe":
             hwe_next = lp.projects[HWE_PUBLIC_PROJECT]
-            sub_url = "%s~%s" % (lp._root_uri, 'canonical-hwe-team')
+            sub_url = "%s~%s" % (lp._root_uri, "canonical-hwe-team")
             pub_bug.subscribe(person=sub_url)
-            remote_bug_tag(pub_bug, 'hwe-needs-public-bug')
+            remote_bug_tag(pub_bug, "hwe-needs-public-bug")
         elif ihv == "swe":
             hwe_next = lp.projects[OEM_PUBLIC_PROJECT]
-            sub_url = "%s~%s" % (lp._root_uri, 'oem-solutions-engineers')
+            sub_url = "%s~%s" % (lp._root_uri, "oem-solutions-engineers")
             pub_bug.subscribe(person=sub_url)
-            remote_bug_tag(pub_bug, 'swe-needs-public-bug')
+            remote_bug_tag(pub_bug, "swe-needs-public-bug")
         else:
             if lp.projects[ihv]:
                 hwe_next = lp.projects[ihv]
-                remote_bug_tag(pub_bug, 'hwe-needs-public-bug')
+                remote_bug_tag(pub_bug, "hwe-needs-public-bug")
             else:
-                log.error('Project ' + ihv + ' not defined')
+                log.error("Project " + ihv + " not defined")
 
-        add_bug_tags(pub_bug, ['originate-from-' + str(bug.id),
-                               bug.bug_tasks_collection[0].bug_target_name,  # OEM codename
-                               'oem-priority'])
+        add_bug_tags(
+            pub_bug,
+            [
+                "originate-from-" + str(bug.id),
+                bug.bug_tasks_collection[0].bug_target_name,  # OEM codename
+                "oem-priority",
+            ],
+        )
 
     add_bug_task(pub_bug, hwe_next)
 
 
 def link_priv_bugs(main_bugnum, privates, ihv):
-    assert(main_bugnum.isdigit())
+    assert main_bugnum.isdigit()
     login = LaunchpadLogin()
     lp = login.lp
     main_bug = lp.bugs[main_bugnum]
@@ -73,7 +79,7 @@ def link_priv_bugs(main_bugnum, privates, ihv):
 
     # Add X-HWE-Bug: tag to description.
     for priv in privates:
-        assert(priv.isdigit())
+        assert priv.isdigit()
         bug = lp.bugs[priv]
 
         if re.search(tag, bug.description) is None:
@@ -83,20 +89,20 @@ def link_priv_bugs(main_bugnum, privates, ihv):
         else:
             log.warning("Bug already linked to main bug " + tag)
 
-        add_bug_tags(main_bug, ['originate-from-' + str(bug.id)])
+        add_bug_tags(main_bug, ["originate-from-" + str(bug.id)])
 
 
 def add_bug_task(bug, bug_task):
-    assert(type(bug_task) == lazr.restfulclient.resource.Entry)
+    assert type(bug_task) == lazr.restfulclient.resource.Entry
 
     # Check if already have the requested
     for i in bug.bug_tasks:
         if bug_task.name == i.bug_target_name:
-            log.warning('Also-affects on {} already complete.'.format(bug_task))
+            log.warning("Also-affects on {} already complete.".format(bug_task))
             return
     bug.addTask(target=bug_task)
     bug.lp_save()
-    log.info('Also-affects on {} successful.'.format(bug_task))
+    log.info("Also-affects on {} successful.".format(bug_task))
 
 
 def remote_bug_tag(bug, tag):
@@ -110,7 +116,7 @@ def remote_bug_tag(bug, tag):
 
 def add_bug_tags(bug, tags):
     """ add tags to the bug. """
-    log.info('Add tags {} to bug {}'.format(tags, bug.web_link))
+    log.info("Add tags {} to bug {}".format(tags, bug.web_link))
     new_tags = []
     for tag_to_add in tags:
         if tag_to_add not in bug.tags:
@@ -119,7 +125,7 @@ def add_bug_tags(bug, tags):
     bug.lp_save()
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     description = """bind private bugs with pubilc bug
 bud-bind -p bugnumber private_bugnumber1 private_bugnumber2"""
     help = """The expected live cycle of an oem-priority bug is:
@@ -127,11 +133,26 @@ bud-bind -p bugnumber private_bugnumber1 private_bugnumber2"""
     2. SWE/HWE manually create a public bug.
     3. Use bug-bind to bind public and private bug."""
 
-    parser = argparse.ArgumentParser(description=description, epilog=help, formatter_class=argparse.RawDescriptionHelpFormatter)
-    parser.add_argument('-m', '--main', help='main bug for private bugs')
-    parser.add_argument('-p', '--public', help='The public bug number')
-    parser.add_argument('-i', '--ihv', help='Launchpad project name for IHV\nExpecting "swe", "hwe", "intel", "amd", "nvidia", "lsi", "emulex"', default='swe')
-    parser.add_argument('-v', '--vebose', help='shows debug messages', action='store_true', default=False)
+    parser = argparse.ArgumentParser(
+        description=description,
+        epilog=help,
+        formatter_class=argparse.RawDescriptionHelpFormatter,
+    )
+    parser.add_argument("-m", "--main", help="main bug for private bugs")
+    parser.add_argument("-p", "--public", help="The public bug number")
+    parser.add_argument(
+        "-i",
+        "--ihv",
+        help='Launchpad project name for IHV\nExpecting "swe", "hwe", "intel", "amd", "nvidia", "lsi", "emulex"',
+        default="swe",
+    )
+    parser.add_argument(
+        "-v",
+        "--vebose",
+        help="shows debug messages",
+        action="store_true",
+        default=False,
+    )
     # TODO
     # parser.add_argument('-c', '--clean', help='unlnk the bug between public and private', action='store_true', default=False)
 
@@ -139,7 +160,9 @@ bud-bind -p bugnumber private_bugnumber1 private_bugnumber2"""
     if args.vebose:
         log.setLevel(logging.DEBUG)
     if args.ihv not in ["swe", "hwe", "intel", "amd", "nvidia", "lsi", "emulex"]:
-        raise Exception('Expecting "swe", "hwe", "intel", "amd", "nvidia", "lsi", "emulex" for ihv')
+        raise Exception(
+            'Expecting "swe", "hwe", "intel", "amd", "nvidia", "lsi", "emulex" for ihv'
+        )
     if len(private_bugs) == 0:
         parser.error("must provide private bug numbers.")
     if args.main:
diff --git a/copyPackage.py b/copyPackage.py
index 5358674..c6c0b5c 100755
--- a/copyPackage.py
+++ b/copyPackage.py
@@ -1,7 +1,8 @@
 #!/usr/bin/python
 import sys
 from launchpadlib.launchpad import Launchpad
-launchpad = Launchpad.login_with('test', "production")
+
+launchpad = Launchpad.login_with("test", "production")
 
 
 def getValueWithDefault(prompt, default):
@@ -10,8 +11,9 @@ def getValueWithDefault(prompt, default):
     return result and result or default
 
 
-from_pocket = getValueWithDefault("From Pocket (Proposed|Updates|Release...)?",
-                                  "Proposed")
+from_pocket = getValueWithDefault(
+    "From Pocket (Proposed|Updates|Release...)?", "Proposed"
+)
 
 team = None
 while not team:
@@ -29,8 +31,7 @@ while not ppa:
     except e:
         print("Invalid ppa name")
 
-to_pocket = getValueWithDefault("To Pocket (Proposed|Updates|Release...)?",
-                                "Release")
+to_pocket = getValueWithDefault("To Pocket (Proposed|Updates|Release...)?", "Release")
 to_series = getValueWithDefault("To Series?", "precise")
 
 # Get link to ubuntu archive
@@ -42,33 +43,37 @@ while True:
 
     # View packages in ubuntu archive
     pkgs = archive.getPublishedSources(
-        source_name=package_name, pocket=from_pocket, status="Published")
+        source_name=package_name, pocket=from_pocket, status="Published"
+    )
 
     while True:
         print("\n----")
         names = [p.display_name for p in pkgs]
         for i, name in enumerate(names):
-            print " %d: %s" % (i, name)
+            print(" %d: %s" % (i, name))
         print("----\n")
-        i = raw_input("Enter pkg to transfer (0..%d/[Q]uit/[a]nother)> "
-                      % (len(names) - 1))
+        i = raw_input(
+            "Enter pkg to transfer (0..%d/[Q]uit/[a]nother)> " % (len(names) - 1)
+        )
         try:
             pkg = pkgs[int(i)]
 
             print("Ready to copy package %s" % pkg.display_name)
-            if raw_input("Confirm: [Y/n]").lower()[:1] != 'n':
+            if raw_input("Confirm: [Y/n]").lower()[:1] != "n":
                 pass
-                ppa.syncSource(from_archive=archive,
-                               include_binaries=True,
-                               source_name=pkg.display_name.split()[0],
-                               to_pocket=to_pocket,
-                               to_series=to_series,
-                               version=pkg.source_package_version)
+                ppa.syncSource(
+                    from_archive=archive,
+                    include_binaries=True,
+                    source_name=pkg.display_name.split()[0],
+                    to_pocket=to_pocket,
+                    to_series=to_series,
+                    version=pkg.source_package_version,
+                )
 
         except (ValueError, IndexError):
-            if i.lower()[:1] == 'q':
+            if i.lower()[:1] == "q":
                 print("Quitting")
                 sys.exit(0)
-            if i.lower()[:1] == 'a':
+            if i.lower()[:1] == "a":
                 break
             print("invalid input\n")
diff --git a/debian/changelog b/debian/changelog
index da72513..02a4499 100644
--- a/debian/changelog
+++ b/debian/changelog
@@ -1,3 +1,22 @@
+oem-scripts (0.98) UNRELEASED; urgency=medium
+
+  * Black all Python files.
+  * debian/control,
+    debian/rules: Use black to check all Python files.
+  * tests/test_flake8: Ignore W503 because it is incompatible with PEP 8.
+  * tests/test_flake8: Ignore E203 because flake8 doesn't deal with it well
+    and black will cover it.
+  * debian/rules,
+    tests/test_black: Move the black check script out of debian/rules so
+    people can use it to test Python files directly.
+  * debian/control,
+    debian/rules,
+    tests/test_flake8,
+    tests/test_pep8: Remove the pep8 check because flake8 will use
+    pycodestyle (formerly called pep8) to check.
+
+ -- Shih-Yuan Lee (FourDollars) <[e-mail]>  Wed, 09 Jun 2021 20:55:21 +0800
+
 oem-scripts (0.97) focal; urgency=medium
 
   * pkg-oem-meta: Add linux-oem-20.04c parameter support
diff --git a/debian/control b/debian/control
index f9e9d76..b805787 100644
--- a/debian/control
+++ b/debian/control
@@ -2,10 +2,10 @@ Source: oem-scripts
 Section: admin
 Priority: optional
 Build-Depends:
+ black,
  debhelper (>=11),
  dh-python,
  flake8,
- pep8,
  python3-all,
  python3-debian,
  python3-launchpadlib,
diff --git a/debian/rules b/debian/rules
index a739670..98284ec 100755
--- a/debian/rules
+++ b/debian/rules
@@ -5,6 +5,6 @@
 	dh $@ --with python3 --buildsystem=pybuild
 
 override_dh_auto_test:
+	./tests/test_black
 	./tests/test_flake8
-	./tests/test_pep8
 	./tests/test_shellcheck
diff --git a/get-oem-auth-token b/get-oem-auth-token
index d3e8428..2e8c679 100755
--- a/get-oem-auth-token
+++ b/get-oem-auth-token
@@ -23,7 +23,7 @@ def prompt_for_credentials():
     """
     Return username and password collected from stdin.
     """
-    print("\rEmail: ", file=sys.stderr, end='')
+    print("\rEmail: ", file=sys.stderr, end="")
     username = input()
     password = getpass.getpass(stream=sys.stderr)
     return username, password
@@ -41,7 +41,7 @@ def prompt_for_code():
     """
     Return code collected from stdin.
     """
-    print("\r2FA Code: ", file=sys.stderr, end='')
+    print("\r2FA Code: ", file=sys.stderr, end="")
     return input()
 
 
@@ -52,14 +52,16 @@ def get_session_cookie(browser=get_browser(), args=None):
     """
 
     prop = {
-        'oem-ibs': {
+        "oem-ibs": {
             "name": "oem-ibs.canonical.com",
             "url": "https://oem-ibs.canonical.com/builds/",
-            "session": "sessionid"},
-        'oem-share': {
+            "session": "sessionid",
+        },
+        "oem-share": {
             "name": "oem-share.canonical.com",
             "url": "https://oem-share.canonical.com/oem/cesg-builds/",
-            "session": "pysid"}
+            "session": "pysid",
+        },
     }
 
     bad_creds = False
@@ -75,8 +77,7 @@ def get_session_cookie(browser=get_browser(), args=None):
         return
     server = prop[args.server]
 
-    print("Authenticating %s with Ubuntu SSO..." % args.server,
-          file=sys.stderr)
+    print("Authenticating %s with Ubuntu SSO..." % args.server, file=sys.stderr)
     browser.open(server["url"])
     # apachd2-openid
     try:
@@ -144,15 +145,16 @@ def get_session_cookie(browser=get_browser(), args=None):
 
 def main():
     parser = argparse.ArgumentParser(
-        description='Retrieve Canonical internal websites session ID',
-        formatter_class=argparse.ArgumentDefaultsHelpFormatter)
-    parser.add_argument("server",
-                        help="Specify server identifier [oem-ibs|oem-share]")
+        description="Retrieve Canonical internal websites session ID",
+        formatter_class=argparse.ArgumentDefaultsHelpFormatter,
+    )
+    parser.add_argument("server", help="Specify server identifier [oem-ibs|oem-share]")
     parser.add_argument("-u", "--username", help="Specify user's email")
     parser.add_argument("-p", "--password", help="Specify password")
     parser.add_argument("-c", "--code", help="Specify 2-factor code")
-    parser.add_argument("-r", "--retry", help="Sepcify authentication retry",
-                        type=int, default=3)
+    parser.add_argument(
+        "-r", "--retry", help="Sepcify authentication retry", type=int, default=3
+    )
     args = parser.parse_args()
     result = 1
     try:
diff --git a/get-oemshare-auth-token b/get-oemshare-auth-token
index 7e1379b..182649f 100755
--- a/get-oemshare-auth-token
+++ b/get-oemshare-auth-token
@@ -18,7 +18,7 @@ def prompt_for_credentials():
     """
     Return username and password collected from stdin.
     """
-    print("\rEmail: ", file=sys.stderr, end='')
+    print("\rEmail: ", file=sys.stderr, end="")
     username = input()
     password = getpass.getpass(stream=sys.stderr)
     return username, password
@@ -28,7 +28,7 @@ def prompt_for_code():
     """
     Return code collected from stdin.
     """
-    print("\r2FA Code: ", file=sys.stderr, end='')
+    print("\r2FA Code: ", file=sys.stderr, end="")
     return input()
 
 
diff --git a/lp-bug b/lp-bug
index 6bfb087..e76abb2 100755
--- a/lp-bug
+++ b/lp-bug
@@ -30,77 +30,94 @@ from logging import debug, warning, info, critical
 from oem_scripts.LaunchpadLogin import LaunchpadLogin
 from tempfile import TemporaryDirectory
 
-parser = argparse.ArgumentParser(formatter_class=argparse.RawDescriptionHelpFormatter,
-                                 epilog="""
+parser = argparse.ArgumentParser(
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 examples:
     lp-bug copy --output=target_bug_id SOURCE_BUG_ID
     lp-bug cleanup BUG_ID
-    lp-bug cqa-verify [BUG_ID]""")
+    lp-bug cqa-verify [BUG_ID]""",
+)
 
-parser.add_argument("-d", "--debug",
-                    help="print debug messages", action="store_true")
-parser.add_argument("-q", "--quiet",
-                    help="Don't print info messages", action="store_true")
+parser.add_argument("-d", "--debug", help="print debug messages", action="store_true")
+parser.add_argument(
+    "-q", "--quiet", help="Don't print info messages", action="store_true"
+)
 
 subparsers = parser.add_subparsers(dest="subcommand")
 
-copy = subparsers.add_parser('copy', help='[-h] [-o=targetBugID|--output=targetBugID] sourceBugID')
-copy.add_argument("-o", "--output",
-                  help="Specify a file name to write the bug number.",
-                  type=argparse.FileType('w', encoding='UTF-8'))
-copy.add_argument("-t", "--target",
-                  help="Specify the target project, 'oem-priority' by default.",
-                  type=str)
-copy.add_argument("bugID",
-                  help="Specify the bug number on Launchpad to copy from.", type=int)
-copy.add_argument("--public",
-                  help="Make the bug public.", action="store_true")
-
-cleanup = subparsers.add_parser('cleanup', help='[-h] [--yes] bugID')
-cleanup.add_argument("bugID",
-                     help="Specify the bug number on Launchpad to clean up.", type=int)
-cleanup.add_argument("--yes",
-                     help="Say yes for all prompts.", action="store_true")
-
-cqa_verify = subparsers.add_parser('cqa-verify', help='[-h] [--yes] [--dry-run] [bugID]',
-                                   formatter_class=argparse.RawDescriptionHelpFormatter,
-                                   epilog="""
-The 'cqa-verify' subcommand will check the versions in the production archive automatically.""")
-cqa_verify.add_argument("--yes",
-                        help="Say yes for all prompts.", action="store_true")
-cqa_verify.add_argument("--dry-run",
-                        help="Dry run the process.", action="store_true")
-cqa_verify.add_argument('bugID', nargs='?', type=int)
+copy = subparsers.add_parser(
+    "copy", help="[-h] [-o=targetBugID|--output=targetBugID] sourceBugID"
+)
+copy.add_argument(
+    "-o",
+    "--output",
+    help="Specify a file name to write the bug number.",
+    type=argparse.FileType("w", encoding="UTF-8"),
+)
+copy.add_argument(
+    "-t",
+    "--target",
+    help="Specify the target project, 'oem-priority' by default.",
+    type=str,
+)
+copy.add_argument(
+    "bugID", help="Specify the bug number on Launchpad to copy from.", type=int
+)
+copy.add_argument("--public", help="Make the bug public.", action="store_true")
+
+cleanup = subparsers.add_parser("cleanup", help="[-h] [--yes] bugID")
+cleanup.add_argument(
+    "bugID", help="Specify the bug number on Launchpad to clean up.", type=int
+)
+cleanup.add_argument("--yes", help="Say yes for all prompts.", action="store_true")
+
+cqa_verify = subparsers.add_parser(
+    "cqa-verify",
+    help="[-h] [--yes] [--dry-run] [bugID]",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
+The 'cqa-verify' subcommand will check the versions in the production archive automatically.""",
+)
+cqa_verify.add_argument("--yes", help="Say yes for all prompts.", action="store_true")
+cqa_verify.add_argument("--dry-run", help="Dry run the process.", action="store_true")
+cqa_verify.add_argument("bugID", nargs="?", type=int)
 
 args = parser.parse_args()
 
-logging.addLevelName(logging.DEBUG,
-                     "\033[1;96m%s\033[1;0m" %
-                     logging.getLevelName(logging.DEBUG))
-logging.addLevelName(logging.INFO,
-                     "\033[1;32m%s\033[1;0m" %
-                     logging.getLevelName(logging.INFO))
-logging.addLevelName(logging.WARNING,
-                     "\033[1;33m%s\033[1;0m" %
-                     logging.getLevelName(logging.WARNING))
-logging.addLevelName(logging.ERROR,
-                     "\033[1;31m%s\033[1;0m" %
-                     logging.getLevelName(logging.ERROR))
-logging.addLevelName(logging.CRITICAL,
-                     "\033[1;41m%s\033[1;0m" %
-                     logging.getLevelName(logging.CRITICAL))
+logging.addLevelName(
+    logging.DEBUG, "\033[1;96m%s\033[1;0m" % logging.getLevelName(logging.DEBUG)
+)
+logging.addLevelName(
+    logging.INFO, "\033[1;32m%s\033[1;0m" % logging.getLevelName(logging.INFO)
+)
+logging.addLevelName(
+    logging.WARNING, "\033[1;33m%s\033[1;0m" % logging.getLevelName(logging.WARNING)
+)
+logging.addLevelName(
+    logging.ERROR, "\033[1;31m%s\033[1;0m" % logging.getLevelName(logging.ERROR)
+)
+logging.addLevelName(
+    logging.CRITICAL, "\033[1;41m%s\033[1;0m" % logging.getLevelName(logging.CRITICAL)
+)
 
 if args.debug:
-    logging.basicConfig(format='<%(levelname)s> %(message)s',
-                        level=logging.DEBUG,
-                        handlers=[logging.StreamHandler(sys.stdout)])
+    logging.basicConfig(
+        format="<%(levelname)s> %(message)s",
+        level=logging.DEBUG,
+        handlers=[logging.StreamHandler(sys.stdout)],
+    )
 elif not args.quiet:
-    logging.basicConfig(format='<%(levelname)s> %(message)s',
-                        level=logging.INFO,
-                        handlers=[logging.StreamHandler(sys.stdout)])
+    logging.basicConfig(
+        format="<%(levelname)s> %(message)s",
+        level=logging.INFO,
+        handlers=[logging.StreamHandler(sys.stdout)],
+    )
 else:
-    logging.basicConfig(format='<%(levelname)s> %(message)s',
-                        handlers=[logging.StreamHandler(sys.stdout)])
+    logging.basicConfig(
+        format="<%(levelname)s> %(message)s",
+        handlers=[logging.StreamHandler(sys.stdout)],
+    )
 
 
 def _yes_or_ask(yes: bool, message: str) -> bool:
@@ -111,7 +128,7 @@ def _yes_or_ask(yes: bool, message: str) -> bool:
         res = input(f"> \033[1;34m{message}\033[1;0m (y/n) ").lower()
         if res not in {"y", "n"}:
             continue
-        if res == 'y':
+        if res == "y":
             return True
         else:
             return False
@@ -125,7 +142,7 @@ def copy_bug(lp, bug_number: int, target: str, public: bool, output=None) -> Non
         project = lp.projects["oem-priority"]
 
     if public:
-        information_type = 'Public'
+        information_type = "Public"
     else:
         information_type = bug.information_type
 
@@ -134,7 +151,8 @@ def copy_bug(lp, bug_number: int, target: str, public: bool, output=None) -> Non
         target=project,
         title=bug.title,
         information_type=information_type,
-        tags=bug.tags)
+        tags=bug.tags,
+    )
     info(f'LP: #{new_bug.id} - "{new_bug.title}" is created. {new_bug.web_link}')
     if output:
         output.write(f"{new_bug.id}\n")
@@ -142,7 +160,10 @@ def copy_bug(lp, bug_number: int, target: str, public: bool, output=None) -> Non
 
 def cleanup_bug(lp, bug_number: int, yes: bool) -> None:
     bug = lp.bugs[bug_number]
-    if not _yes_or_ask(yes, f'Do you want to cleanup all information on LP: #{bug_number} - "{bug.title}"? {bug.web_link}'):
+    if not _yes_or_ask(
+        yes,
+        f'Do you want to cleanup all information on LP: #{bug_number} - "{bug.title}"? {bug.web_link}',
+    ):
         return
 
     if bug.title != "null":
@@ -159,14 +180,17 @@ def cleanup_bug(lp, bug_number: int, yes: bool) -> None:
     found = False
 
     for bug_task in bug.bug_tasks:
-        if bug_task.bug_target_name == 'null-and-void':
+        if bug_task.bug_target_name == "null-and-void":
             found = True
 
-    if not found and bug.information_type == 'Public':
+    if not found and bug.information_type == "Public":
         bug.addTask(target=lp.projects["null-and-void"])
 
     for bug_task in bug.bug_tasks:
-        if bug_task.bug_target_name != 'null-and-void' and bug.information_type == 'Public':
+        if (
+            bug_task.bug_target_name != "null-and-void"
+            and bug.information_type == "Public"
+        ):
             try:
                 bug_task.lp_delete()
             except lazr.restfulclient.errors.BadRequest as e:
@@ -183,21 +207,27 @@ def cleanup_bug(lp, bug_number: int, yes: bool) -> None:
         if subscription.canBeUnsubscribedByUser():
             bug.unsubscribe(person=lp.people[subscription.person.name])
         else:
-            warning(f"{lp.me.name} doesn't have the permission to unsubscribe {subscription.person.name}.")
+            warning(
+                f"{lp.me.name} doesn't have the permission to unsubscribe {subscription.person.name}."
+            )
 
-    info(f'LP: #{bug.id} has been cleaned. {bug.web_link}')
+    info(f"LP: #{bug.id} has been cleaned. {bug.web_link}")
 
 
-def _run_command(command: list or tuple, returncode=(0,), env=None, silent=False) -> (str, str, int):
+def _run_command(
+    command: list or tuple, returncode=(0,), env=None, silent=False
+) -> (str, str, int):
     if not silent:
         debug("$ " + " ".join(command))
-    proc = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
+    proc = subprocess.Popen(
+        command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env
+    )
     out, err = proc.communicate()
 
     if out:
-        out = out.decode('utf-8').strip()
+        out = out.decode("utf-8").strip()
     if err:
-        err = err.decode('utf-8').strip()
+        err = err.decode("utf-8").strip()
 
     if proc.returncode not in returncode:
         critical(f"return {proc.returncode}")
@@ -216,44 +246,46 @@ def _run_command(command: list or tuple, returncode=(0,), env=None, silent=False
     return (out, err, proc.returncode)
 
 
-pattern = re.compile(r'(.*) \(==(.*)\)')
+pattern = re.compile(r"(.*) \(==(.*)\)")
 
 
 def cloudberry_cqa_verified(lp, yes: bool, bugID: int) -> None:
-    cloudberry = lp.projects['cloudberry']
+    cloudberry = lp.projects["cloudberry"]
     # Only deal with those bugs with 'Fix Committed' and 'request of publish_package' in the title.
-    tasks = cloudberry.searchTasks(status=['Fix Committed'], search_text='request of publish_package')
+    tasks = cloudberry.searchTasks(
+        status=["Fix Committed"], search_text="request of publish_package"
+    )
     for task in tasks:
         bug = task.bug
         # Only deal with one bug id when it is provided.
         if bugID and bug.id != bugID:
             continue
         # Only deal with those bugs with this tag.
-        if 'cqa-verified-staging' not in bug.tags:
+        if "cqa-verified-staging" not in bug.tags:
             continue
         info(f'LP: #{bug.id} "{bug.title}"\n{bug.description}')
         debug(bug.tags)
         multiple = False
         packages = []
         prod_archive_line = ""
-        lines = bug.description.split('\n')
+        lines = bug.description.split("\n")
         # Parse the package list and the production archive in the bug description.
         for idx, line in enumerate(lines):
-            if line.startswith('Package: '):
+            if line.startswith("Package: "):
                 debug(line)
-                if line.endswith(','):
+                if line.endswith(","):
                     multiple = True
                     packages.append(line[9:-1])
                 else:
-                    packages = line[9:].split(',')
+                    packages = line[9:].split(",")
             elif multiple is True:
                 debug(line)
-                if not line.endswith(','):
+                if not line.endswith(","):
                     multiple = False
                     packages.append(line.strip())
                 else:
                     packages.append(line.strip()[:-1])
-            elif 'production archive' in line:
+            elif "production archive" in line:
                 prod_archive_line = lines[idx + 2]
         # Skip the bug when it found no production archive.
         if not prod_archive_line:
@@ -272,9 +304,9 @@ def cloudberry_cqa_verified(lp, yes: bool, bugID: int) -> None:
         # Check if the production archive provided the packages and versions.
         with TemporaryDirectory() as tmpdir:
             failed = False
-            fingerprint = 'F9FDA6BED73CDC22'
-            series = ['focal', 'bionic', 'xenial']
-            codename = ''
+            fingerprint = "F9FDA6BED73CDC22"
+            series = ["focal", "bionic", "xenial"]
+            codename = ""
             for item in series:
                 if item in prod_archive_line:
                     codename = item
@@ -284,23 +316,32 @@ def cloudberry_cqa_verified(lp, yes: bool, bugID: int) -> None:
                 continue
             # Setup the temporary apt dir to include the production archive.
             output, _, returncode = _run_command(
-                ['setup-apt-dir.sh',
-                 '-c', codename,
-                 '--disable-updates',
-                 '--disable-backports',
-                 '--apt-dir', tmpdir,
-                 '--extra-key', fingerprint,
-                 '--extra-repo', prod_archive_line.replace("deb ", f"deb [signed-by={tmpdir}/{fingerprint}.pub] ")
-                 ], returncode=(0, 100))
+                [
+                    "setup-apt-dir.sh",
+                    "-c",
+                    codename,
+                    "--disable-updates",
+                    "--disable-backports",
+                    "--apt-dir",
+                    tmpdir,
+                    "--extra-key",
+                    fingerprint,
+                    "--extra-repo",
+                    prod_archive_line.replace(
+                        "deb ", f"deb [signed-by={tmpdir}/{fingerprint}.pub] "
+                    ),
+                ],
+                returncode=(0, 100),
+            )
             # Skip the bug when it found some error in the production archive.
             if returncode == 100:
                 warning(output)
                 continue
             # Use the temporary apt dir to compare the package versions.
             for pkg, ver in packages:
-                output, _, _ = _run_command(['pkg-list', '--apt-dir', tmpdir, pkg])
-                for line in output.split('\n'):
-                    archive_pkg, archive_ver = line.split(' ')
+                output, _, _ = _run_command(["pkg-list", "--apt-dir", tmpdir, pkg])
+                for line in output.split("\n"):
+                    archive_pkg, archive_ver = line.split(" ")
                     if pkg == archive_pkg:
                         if apt_pkg.version_compare(archive_ver, ver) >= 0:
                             print(f"{line} >= {ver}")
@@ -309,9 +350,12 @@ def cloudberry_cqa_verified(lp, yes: bool, bugID: int) -> None:
                             failed = True
             # Tag "cqa-verified" if no failure.
             if not failed:
-                if not args.dry_run and _yes_or_ask(yes, f'Would you like to tag "cqa-verified" for LP: #{bug.id} "{bug.title}"?'):
+                if not args.dry_run and _yes_or_ask(
+                    yes,
+                    f'Would you like to tag "cqa-verified" for LP: #{bug.id} "{bug.title}"?',
+                ):
                     tags = bug.tags.copy()
-                    tags.append('cqa-verified')
+                    tags.append("cqa-verified")
                     if f"oem-scripts-{oem_scripts.__version__}" not in tags:
                         tags.append(f"oem-scripts-{oem_scripts.__version__}")
                     bug.tags = tags
@@ -322,11 +366,11 @@ if args.subcommand:
     login = LaunchpadLogin()
     lp = login.lp
 
-if args.subcommand == 'copy':
+if args.subcommand == "copy":
     copy_bug(lp, args.bugID, output=args.output, target=args.target, public=args.public)
-elif args.subcommand == 'cleanup':
+elif args.subcommand == "cleanup":
     cleanup_bug(lp, args.bugID, args.yes)
-elif args.subcommand == 'cqa-verify':
+elif args.subcommand == "cqa-verify":
     cloudberry_cqa_verified(lp, args.yes, args.bugID)
 else:
     parser.print_help()
diff --git a/mir-bug b/mir-bug
index dee3a25..9683a3b 100755
--- a/mir-bug
+++ b/mir-bug
@@ -36,75 +36,108 @@ from oem_scripts.logging import setup_logging
 from string import Template
 from tempfile import TemporaryDirectory
 
-SUBSCRIBER_LIST = ('oem-solutions-engineers', 'ubuntu-sponsors', 'ubuntu-desktop')
-TAG_LIST = ('oem-meta-packages', 'oem-priority', f'oem-scripts-{oem_scripts.__version__:.2f}')
-
-parser = argparse.ArgumentParser(formatter_class=argparse.RawDescriptionHelpFormatter,
-                                 epilog="""
+SUBSCRIBER_LIST = ("oem-solutions-engineers", "ubuntu-sponsors", "ubuntu-desktop")
+TAG_LIST = (
+    "oem-meta-packages",
+    "oem-priority",
+    f"oem-scripts-{oem_scripts.__version__:.2f}",
+)
+
+parser = argparse.ArgumentParser(
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 examples:
     mir-bug create sutton.newell ace \"ThinkPad X1 Carbon Gen 8\"
     mir-bug check BUG_NUMBER
     mir-bug update BUG_NUMBER
-    mir-bug collect oem-meta-mir-bugs.json""")
+    mir-bug collect oem-meta-mir-bugs.json""",
+)
 
-parser.add_argument("-d", "--debug",
-                    help="print debug messages", action="store_true")
-parser.add_argument("-q", "--quiet",
-                    help="Don't print info messages", action="store_true")
+parser.add_argument("-d", "--debug", help="print debug messages", action="store_true")
+parser.add_argument(
+    "-q", "--quiet", help="Don't print info messages", action="store_true"
+)
 
 subparsers = parser.add_subparsers(dest="subcommand")
 
-create = subparsers.add_parser('create', help='[-h] [-o=bugID|--output=bugID] oemCodename platformCodename deviceName')
-create.add_argument("oemCodename",
-                    help="Such as somerville, stella, or sutton.simon")
-create.add_argument("platformCodename",
-                    help="Name deined by PM, like ace.")
-create.add_argument("deviceName",
-                    help="ThinkPad X1 Carbon Gen 8")
-create.add_argument("-o", "--output",
-                    help="Specify a file name to write the bug number.",
-                    type=argparse.FileType('w', encoding='UTF-8'))
-
-update = subparsers.add_parser('update', help='[-h] [--ready] [--skip] [--tz=UTC-8] [--yes] bugNumber')
-update.add_argument("bugNumber",
-                    help="Specify the bug number on Launchpad to update.", type=int)
-update.add_argument("--yes",
-                    help="Say yes for all prompts.", action="store_true")
-update.add_argument("--skip",
-                    help="Skip updating bootstrap branch of Git repository.", action="store_true")
-update.add_argument("--tz",
-                    help="Specify the value for TZ. (UTC-8 by default)", default="UTC-8")
-update.add_argument("--ready",
-                    action="store_true",
-                    help="Update the bug to Fix Committed, also affects 'Ubuntu', and subscribe 'ubuntu-sponsors' and 'ubuntu-desktop'.")
-
-check = subparsers.add_parser('check', help='[-h] [--ready] [--skip] [--tz=UTC-8] bugNumber')
-check.add_argument("bugNumber",
-                   help="Specify the bug number on Launchpad to do some sanity checks.", type=int)
-check.add_argument("--skip",
-                   help="Skip checking oem branch of Git repository.", action="store_true")
-check.add_argument("--tz",
-                   help="Specify the value for TZ. (UTC-8 by default)", default="UTC-8")
-check.add_argument("--ready",
-                   action="store_true",
-                   help="Check if the bug is Fix Committed, also affects 'Ubuntu', and subscribe 'ubuntu-sponsors' and 'ubuntu-desktop'.")
-
-collect = subparsers.add_parser('collect', help='[-h] [--ubuntu-certified] jsonFile')
-collect.add_argument("json",
-                     help="Specify the json file name to write.",
-                     type=argparse.FileType('w', encoding='UTF-8'))
-collect.add_argument("--ubuntu-certified",
-                     action="store_true",
-                     help="Only collect those bugs with the 'ubuntu-certified' tag.")
-collect.add_argument("--verification-needed",
-                     action="store_true",
-                     help="Only collect those bugs with the 'verification-needed' tag.")
+create = subparsers.add_parser(
+    "create",
+    help="[-h] [-o=bugID|--output=bugID] oemCodename platformCodename deviceName",
+)
+create.add_argument("oemCodename", help="Such as somerville, stella, or sutton.simon")
+create.add_argument("platformCodename", help="Name deined by PM, like ace.")
+create.add_argument("deviceName", help="ThinkPad X1 Carbon Gen 8")
+create.add_argument(
+    "-o",
+    "--output",
+    help="Specify a file name to write the bug number.",
+    type=argparse.FileType("w", encoding="UTF-8"),
+)
+
+update = subparsers.add_parser(
+    "update", help="[-h] [--ready] [--skip] [--tz=UTC-8] [--yes] bugNumber"
+)
+update.add_argument(
+    "bugNumber", help="Specify the bug number on Launchpad to update.", type=int
+)
+update.add_argument("--yes", help="Say yes for all prompts.", action="store_true")
+update.add_argument(
+    "--skip",
+    help="Skip updating bootstrap branch of Git repository.",
+    action="store_true",
+)
+update.add_argument(
+    "--tz", help="Specify the value for TZ. (UTC-8 by default)", default="UTC-8"
+)
+update.add_argument(
+    "--ready",
+    action="store_true",
+    help="Update the bug to Fix Committed, also affects 'Ubuntu', and subscribe 'ubuntu-sponsors' and 'ubuntu-desktop'.",
+)
+
+check = subparsers.add_parser(
+    "check", help="[-h] [--ready] [--skip] [--tz=UTC-8] bugNumber"
+)
+check.add_argument(
+    "bugNumber",
+    help="Specify the bug number on Launchpad to do some sanity checks.",
+    type=int,
+)
+check.add_argument(
+    "--skip", help="Skip checking oem branch of Git repository.", action="store_true"
+)
+check.add_argument(
+    "--tz", help="Specify the value for TZ. (UTC-8 by default)", default="UTC-8"
+)
+check.add_argument(
+    "--ready",
+    action="store_true",
+    help="Check if the bug is Fix Committed, also affects 'Ubuntu', and subscribe 'ubuntu-sponsors' and 'ubuntu-desktop'.",
+)
+
+collect = subparsers.add_parser("collect", help="[-h] [--ubuntu-certified] jsonFile")
+collect.add_argument(
+    "json",
+    help="Specify the json file name to write.",
+    type=argparse.FileType("w", encoding="UTF-8"),
+)
+collect.add_argument(
+    "--ubuntu-certified",
+    action="store_true",
+    help="Only collect those bugs with the 'ubuntu-certified' tag.",
+)
+collect.add_argument(
+    "--verification-needed",
+    action="store_true",
+    help="Only collect those bugs with the 'verification-needed' tag.",
+)
 
 args = parser.parse_args()
 
 setup_logging(debug=args.debug, quiet=args.quiet)
 
-mir_bug_description_template = Template(f"""[Availability]
+mir_bug_description_template = Template(
+    f"""[Availability]
 This is a meta package for https://wiki.ubuntu.com/MIRTeam/Exceptions/OEM that means the package doesn't exist in Debian or Ubuntu archive yet.
 The source code of the $metaPkgName for focal:
     git clone -b $branchName https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-$oemCodenameNogroup-projects-meta
@@ -131,26 +164,27 @@ Canonical OEM Enablement Team will take care of the maintenance.
 [Background information]
 Please check https://wiki.ubuntu.com/MIRTeam/Exceptions/OEM for details.
 
-Please use "oem-metapackage-mir-check" in lp:ubuntu-archive-tools to verify this MIR against the reference package in the archive.""")
+Please use "oem-metapackage-mir-check" in lp:ubuntu-archive-tools to verify this MIR against the reference package in the archive."""
+)
 
-pattern = re.compile(r'.*\[MIR\]\W*oem-([^-]*)-(.*)-meta\W*')
+pattern = re.compile(r".*\[MIR\]\W*oem-([^-]*)-(.*)-meta\W*")
 
 
 def create_bug(lp, oemCodename, platformCodename, deviceName):
     info("Creating bug...")
-    tempList = oemCodename.split('.')
+    tempList = oemCodename.split(".")
     oemCodenameNogroup = tempList[0]
     if len(tempList) == 2:
         oemGroupName = tempList[1]
     else:
-        oemGroupName = ''
+        oemGroupName = ""
 
     # metaPkgName's examples
     # oem-somerville-metapod-meta
     # oem-sutton.newell-ace-meta
     metaPkgName = "oem-" + oemCodename + "-" + platformCodename + "-meta"
 
-    if oemGroupName.strip() != '':
+    if oemGroupName.strip() != "":
         branchName = oemGroupName + "." + platformCodename + "-focal-ubuntu"
     else:
         branchName = platformCodename + "-focal-ubuntu"
@@ -162,8 +196,15 @@ def create_bug(lp, oemCodename, platformCodename, deviceName):
         metaPkgName=metaPkgName,
         branchName=branchName,
         oemCodenameNogroup=oemCodenameNogroup,
-        deviceName=deviceName)
-    bug = lp.bugs.createBug(description=bd, target=project, title=bt, information_type='Public', tags=TAG_LIST)
+        deviceName=deviceName,
+    )
+    bug = lp.bugs.createBug(
+        description=bd,
+        target=project,
+        title=bt,
+        information_type="Public",
+        tags=TAG_LIST,
+    )
 
     info("meta package public bug: " + bug.web_link)
 
@@ -171,23 +212,32 @@ def create_bug(lp, oemCodename, platformCodename, deviceName):
         args.output.write(f"{bug.id}\n")
 
     for task in bug.bug_tasks:
-        task.status = 'Confirmed'
-        task.importance = 'Critical'
+        task.status = "Confirmed"
+        task.importance = "Critical"
         # Assign to reporter by default
         task.assignee = lp.me
         task.lp_save()
 
     # Subscribe the oem-solutions-engineers
-    bug.subscribe(person=lp.people['oem-solutions-engineers'])
+    bug.subscribe(person=lp.people["oem-solutions-engineers"])
     bug.lp_save()
 
 
 def collect_bugs(lp, output):
     info("Collecting bugs...")
-    project = lp.projects['oem-priority']
+    project = lp.projects["oem-priority"]
     tasks = project.searchTasks(
-        status=['New', 'Incomplete', 'Triaged', 'Opinion', 'Confirmed', 'In Progress', 'Fix Committed'],
-        search_text='[MIR]')
+        status=[
+            "New",
+            "Incomplete",
+            "Triaged",
+            "Opinion",
+            "Confirmed",
+            "In Progress",
+            "Fix Committed",
+        ],
+        search_text="[MIR]",
+    )
     try:
         total = int(tasks.total_size)
     except TypeError:  # When the total size becomes more than 50, it won't return 'int' but 'ScalarValue' instead.
@@ -197,28 +247,38 @@ def collect_bugs(lp, output):
     for counter, task in enumerate(tasks, 1):
         bug = task.bug
 
-        if '[MIR]' not in bug.title or 'oem' not in bug.title or 'meta' not in bug.title:
-            info(f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT MATCHED**")
+        if (
+            "[MIR]" not in bug.title
+            or "oem" not in bug.title
+            or "meta" not in bug.title
+        ):
+            info(
+                f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT MATCHED**"
+            )
             continue
 
-        if args.ubuntu_certified and 'ubuntu-certified' not in bug.tags:
-            info(f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT CERTIFIED**")
+        if args.ubuntu_certified and "ubuntu-certified" not in bug.tags:
+            info(
+                f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT CERTIFIED**"
+            )
             continue
 
         if args.verification_needed:
             verification_needed = False
             for tag in bug.tags:
-                if tag.startswith('verification-needed'):
+                if tag.startswith("verification-needed"):
                     verification_needed = True
             if not verification_needed:
-                info(f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT VERIFICATION NEEDED**")
+                info(
+                    f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status}) **NOT VERIFICATION NEEDED**"
+                )
                 continue
 
         result = pattern.match(bug.title)
         git = None
         if result:
-            if '.' in result.group(1):
-                project, group = result.group(1).split('.')
+            if "." in result.group(1):
+                project, group = result.group(1).split(".")
             else:
                 project = result.group(1)
                 group = None
@@ -234,32 +294,38 @@ def collect_bugs(lp, output):
 
         ubuntu_status = None
         for bug_task in bug.bug_tasks:
-            if bug_task.bug_target_name == 'ubuntu':
+            if bug_task.bug_target_name == "ubuntu":
                 ubuntu_status = bug_task.status
 
         attachments = []
         for attachment in bug.attachments:
-            attachments.append({'title': attachment.title, 'data_link': attachment.data_link, 'type': attachment.type})
+            attachments.append(
+                {
+                    "title": attachment.title,
+                    "data_link": attachment.data_link,
+                    "type": attachment.type,
+                }
+            )
         clip = {
-            'bug': "https://bugs.launchpad.net/bugs/%s" % bug.id,
-            'link': bug.self_link,
-            'title': bug.title,
-            'importance': task.importance,
-            'tag': bug.tags,
-            'description': bug.description,
-            'status': task.status,
-            'ubuntu_status': ubuntu_status,
-            'owner': task.owner.name,
-            'assignee': task.assignee.name if task.assignee else 'none',
-            'subscriptions': subscriptions,
-            'attachments': attachments,
-            'git': git
+            "bug": "https://bugs.launchpad.net/bugs/%s" % bug.id,
+            "link": bug.self_link,
+            "title": bug.title,
+            "importance": task.importance,
+            "tag": bug.tags,
+            "description": bug.description,
+            "status": task.status,
+            "ubuntu_status": ubuntu_status,
+            "owner": task.owner.name,
+            "assignee": task.assignee.name if task.assignee else "none",
+            "subscriptions": subscriptions,
+            "attachments": attachments,
+            "git": git,
         }
         bugs.append(clip)
         info(f"{counter}/{total} LP: #{bug.id} {bug.title} ({task.status})")
 
     info("total: %d matched" % len(bugs))
-    output.write(json.dumps(bugs, sort_keys=True, separators=(',', ':')))
+    output.write(json.dumps(bugs, sort_keys=True, separators=(",", ":")))
     output.write("\n")
 
 
@@ -271,7 +337,7 @@ def yes_or_ask(yes: bool, message: str) -> bool:
         res = input(f"> \033[1;34m{message}\033[1;0m (y/n) ").lower()
         if res not in {"y", "n"}:
             continue
-        if res == 'y':
+        if res == "y":
             return True
         else:
             return False
@@ -288,7 +354,9 @@ def update_bug(lp, bug_number: int, yes: bool) -> None:
         bug_modified = True
         bug.description = desc
 
-    if check_bug_title(bug, pkg_name) is False and yes_or_ask(yes, "Do you want to update the bug title?"):
+    if check_bug_title(bug, pkg_name) is False and yes_or_ask(
+        yes, "Do you want to update the bug title?"
+    ):
         bug_modified = True
         bug.title = f"[MIR] {pkg_name}"
 
@@ -298,11 +366,13 @@ def update_bug(lp, bug_number: int, yes: bool) -> None:
 
     if check_bug_importance(bug) is False:
         for task in bug.bug_tasks:
-            if task.importance != 'Critical':
-                if task.bug_target_name == 'oem-priority' and \
-                        yes_or_ask(yes, f"Do you want to update the importance of {task.bug_target_name} from {task.importance} to Critical?"):
+            if task.importance != "Critical":
+                if task.bug_target_name == "oem-priority" and yes_or_ask(
+                    yes,
+                    f"Do you want to update the importance of {task.bug_target_name} from {task.importance} to Critical?",
+                ):
                     task_modified = True
-                    task.importance = 'Critical'
+                    task.importance = "Critical"
                     task.lp_save()
 
     update_bug_status(bug, yes)
@@ -312,12 +382,14 @@ def update_bug(lp, bug_number: int, yes: bool) -> None:
     if check_bug_tags(bug) is False:
         tags = copy(bug.tags)
         for tag in TAG_LIST:
-            if tag not in bug.tags and yes_or_ask(yes, f"Do you want to add '{tag}' tag?"):
+            if tag not in bug.tags and yes_or_ask(
+                yes, f"Do you want to add '{tag}' tag?"
+            ):
                 bug_modified = True
                 tags.append(tag)
         for tag in bug.tags:
-            if tag.startswith('oem-scripts-'):
-                if tag[len("oem-scripts-"):] != f'{oem_scripts.__version__:.2f}':
+            if tag.startswith("oem-scripts-"):
+                if tag[len("oem-scripts-") :] != f"{oem_scripts.__version__:.2f}":
                     if yes_or_ask(yes, f"Do you want to remove '{tag}' tag?"):
                         tags.remove(tag)
         if tags != bug.tags:
@@ -329,11 +401,11 @@ def update_bug(lp, bug_number: int, yes: bool) -> None:
 
     if bug_modified:
         bug.lp_save()
-        info(f'LP: #{bug_number} is updated.')
+        info(f"LP: #{bug_number} is updated.")
     elif task_modified:
-        info(f'LP: #{bug_number} is updated.')
+        info(f"LP: #{bug_number} is updated.")
     elif yes:
-        info('Everything looks OK.')
+        info("Everything looks OK.")
 
 
 def check_bug(lp, bug_number: int) -> None:
@@ -357,11 +429,14 @@ def check_bug(lp, bug_number: int) -> None:
         need_fixing = True
     if check_and_update_bug_attachments(bug, pkg_name) is False:
         need_fixing = True
-    if not args.skip and check_and_update_git_repo(bug, pkg_name, bootstrap=False) is False:
+    if (
+        not args.skip
+        and check_and_update_git_repo(bug, pkg_name, bootstrap=False) is False
+    ):
         need_fixing = True
 
     if need_fixing is False:
-        info('Everything looks OK.')
+        info("Everything looks OK.")
     else:
         exit(1)
 
@@ -373,8 +448,8 @@ def check_bug_description(bug) -> (str, str):
         critical(f"LP: #{bug.id} '{bug.title}' is NOT MATCHED")
         exit(1)
 
-    if '.' in result.group(1):
-        project, group = result.group(1).split('.')
+    if "." in result.group(1):
+        project, group = result.group(1).split(".")
         platform = result.group(2)
         branchName = group + "." + platform + "-focal-ubuntu"
     else:
@@ -384,10 +459,10 @@ def check_bug_description(bug) -> (str, str):
         branchName = platform + "-focal-ubuntu"
 
     metaPkgName = f"oem-{result.group(1)}-{result.group(2)}-meta"
-    prog = re.compile(r'\W*We want to improve the hardware support for ([^.]*).\W*')
+    prog = re.compile(r"\W*We want to improve the hardware support for ([^.]*).\W*")
     deviceName = None
 
-    for line in bug.description.split('\n'):
+    for line in bug.description.split("\n"):
         result = prog.match(line)
         if not result:
             continue
@@ -403,11 +478,12 @@ def check_bug_description(bug) -> (str, str):
         metaPkgName=metaPkgName,
         branchName=branchName,
         oemCodenameNogroup=project,
-        deviceName=deviceName)
+        deviceName=deviceName,
+    )
 
     if bug.description != desc:
         d = difflib.Differ()
-        diff = d.compare(bug.description.split('\n'), desc.split('\n'))
+        diff = d.compare(bug.description.split("\n"), desc.split("\n"))
         error("The description needs to update.")
         if not args.quiet:
             for i, line in enumerate(diff):
@@ -431,15 +507,19 @@ def check_bug_importance(bug) -> bool:
     info("Checking bug importance...")
     result = True
     for task in bug.bug_tasks:
-        if task.bug_target_name == 'oem-priority' and task.importance != 'Critical':
-            error(f"The '{task.bug_target_name}' importance is expected to be 'Critical' instead of '{task.importance}'.")
+        if task.bug_target_name == "oem-priority" and task.importance != "Critical":
+            error(
+                f"The '{task.bug_target_name}' importance is expected to be 'Critical' instead of '{task.importance}'."
+            )
             result = False
     return result
 
 
 def _expected_status(target_name: str, status: str, expected: str) -> bool:
     if status != expected:
-        error(f"The '{target_name}' status is expected to be '{expected}' instead of '{status}'.")
+        error(
+            f"The '{target_name}' status is expected to be '{expected}' instead of '{status}'."
+        )
         return False
     return True
 
@@ -449,20 +529,32 @@ def check_bug_status(bug, pkg_name: str) -> bool:
     result = True
     saw_ubuntu_task = False
     for task in bug.bug_tasks:
-        if task.bug_target_name == 'oem-priority':
+        if task.bug_target_name == "oem-priority":
             if args.ready:
-                if _expected_status(task.bug_target_name, task.status, 'Fix Committed') is False:
+                if (
+                    _expected_status(task.bug_target_name, task.status, "Fix Committed")
+                    is False
+                ):
                     result = False
             else:
-                if _expected_status(task.bug_target_name, task.status, 'In Progress') is False:
+                if (
+                    _expected_status(task.bug_target_name, task.status, "In Progress")
+                    is False
+                ):
                     result = False
-        elif task.bug_target_name == 'ubuntu':
+        elif task.bug_target_name == "ubuntu":
             saw_ubuntu_task = True
             if args.ready:
-                if _expected_status(task.bug_target_name, task.status, 'Confirmed') is False:
+                if (
+                    _expected_status(task.bug_target_name, task.status, "Confirmed")
+                    is False
+                ):
                     result = False
             else:
-                if _expected_status(task.bug_target_name, task.status, 'Incomplete') is False:
+                if (
+                    _expected_status(task.bug_target_name, task.status, "Incomplete")
+                    is False
+                ):
                     result = False
         elif f"{pkg_name} (Ubuntu)" not in task.bug_target_name:
             critical(f"It is unexpected to have '{task.bug_target_name}' task")
@@ -472,17 +564,25 @@ def check_bug_status(bug, pkg_name: str) -> bool:
     return result
 
 
-def _ok_to_change_status(target_name: str, orig_status: str, new_status: str, yes: bool) -> bool:
+def _ok_to_change_status(
+    target_name: str, orig_status: str, new_status: str, yes: bool
+) -> bool:
     if orig_status == new_status:
         return False
-    if yes_or_ask(yes, f"Would you like to change the '{target_name}' status from '{orig_status}' to '{new_status}'?"):
+    if yes_or_ask(
+        yes,
+        f"Would you like to change the '{target_name}' status from '{orig_status}' to '{new_status}'?",
+    ):
         return True
     return False
 
 
 def _change_task_status(task, new_status: str, yes: bool) -> bool:
-    if _expected_status(task.bug_target_name, task.status, new_status) is False and \
-            _ok_to_change_status(task.bug_target_name, task.status, new_status, yes):
+    if _expected_status(
+        task.bug_target_name, task.status, new_status
+    ) is False and _ok_to_change_status(
+        task.bug_target_name, task.status, new_status, yes
+    ):
         task.status = new_status
         task.lp_save()
 
@@ -491,35 +591,42 @@ def update_bug_status(bug, yes: bool) -> None:
     info("Updating bug status...")
     saw_ubuntu_task = False
     for bug_task in bug.bug_tasks:
-        if bug_task.bug_target_name == 'oem-priority':
+        if bug_task.bug_target_name == "oem-priority":
             if args.ready:
-                _change_task_status(bug_task, 'Fix Committed', yes)
+                _change_task_status(bug_task, "Fix Committed", yes)
             else:
-                _change_task_status(bug_task, 'In Progress', yes)
-        elif bug_task.bug_target_name == 'ubuntu':
+                _change_task_status(bug_task, "In Progress", yes)
+        elif bug_task.bug_target_name == "ubuntu":
             saw_ubuntu_task = True
             if args.ready:
-                _change_task_status(bug_task, 'Confirmed', yes)
-            elif yes_or_ask(yes, f"Would you like to delete the '{bug_task.bug_target_name}' bug_task? (Don't affect '{bug_task.bug_target_display_name}')"):
+                _change_task_status(bug_task, "Confirmed", yes)
+            elif yes_or_ask(
+                yes,
+                f"Would you like to delete the '{bug_task.bug_target_name}' bug_task? (Don't affect '{bug_task.bug_target_display_name}')",
+            ):
                 try:
                     bug_task.lp_delete()
                 except lazr.restfulclient.errors.BadRequest as e:
-                    warning(f"{bug_task.bug_target_name} can not be deleted, so changing the status to Incomplete instead.")
+                    warning(
+                        f"{bug_task.bug_target_name} can not be deleted, so changing the status to Incomplete instead."
+                    )
                     debug(e)
-                    _change_task_status(bug_task, 'Incomplete', yes)
+                    _change_task_status(bug_task, "Incomplete", yes)
                 except lazr.restfulclient.errors.Unauthorized as e:
-                    warning(f"{bug_task.bug_target_name} can not be deleted, so changing the status to Incomplete instead.")
+                    warning(
+                        f"{bug_task.bug_target_name} can not be deleted, so changing the status to Incomplete instead."
+                    )
                     debug(e)
-                    _change_task_status(bug_task, 'Incomplete', yes)
+                    _change_task_status(bug_task, "Incomplete", yes)
             else:
-                _change_task_status(bug_task, 'Incomplete', yes)
+                _change_task_status(bug_task, "Incomplete", yes)
         else:
             warning(f"{bug_task.bug_target_name} {bug_task.status}")
     if args.ready and saw_ubuntu_task is False:
         bug.addTask(target=lp.projects["Ubuntu"])
         for bug_task in bug.bug_tasks:
-            if bug_task.bug_target_name == 'ubuntu':
-                _change_task_status(bug_task, 'Confirmed', yes)
+            if bug_task.bug_target_name == "ubuntu":
+                _change_task_status(bug_task, "Confirmed", yes)
 
 
 def check_and_update_bug_subscriptions(lp, bug, update=False, yes=False) -> bool:
@@ -532,29 +639,41 @@ def check_and_update_bug_subscriptions(lp, bug, update=False, yes=False) -> bool
     for subscription in bug.subscriptions:
         subscriptions.append(subscription.person.name)
         if not args.ready:
-            for subscriber in ('ubuntu-sponsors', 'ubuntu-desktop'):
+            for subscriber in ("ubuntu-sponsors", "ubuntu-desktop"):
                 if subscriber == subscription.person.name:
                     error(f"'{subscriber}' should not be in the subscriptions.")
-                    if update and yes_or_ask(yes, f"Do you want to unsubscribe '{subscriber}'?"):
+                    if update and yes_or_ask(
+                        yes, f"Do you want to unsubscribe '{subscriber}'?"
+                    ):
                         if subscription.canBeUnsubscribedByUser():
                             bug.unsubscribe(person=lp.people[subscriber])
                         else:
-                            warning(f"{lp.me.name} doesn't have the permission to unsubscribe {subscriber}.")
+                            warning(
+                                f"{lp.me.name} doesn't have the permission to unsubscribe {subscriber}."
+                            )
                             result = False
                     else:
                         result = False
     if args.ready:
-        for subscriber in ('oem-solutions-engineers', 'ubuntu-sponsors', 'ubuntu-desktop'):
+        for subscriber in (
+            "oem-solutions-engineers",
+            "ubuntu-sponsors",
+            "ubuntu-desktop",
+        ):
             if subscriber not in subscriptions:
                 error(f"'{subscriber}' is not in the subscriptions.")
-                if update and yes_or_ask(yes, f"Do you want to subscribe '{subscriber}'?"):
+                if update and yes_or_ask(
+                    yes, f"Do you want to subscribe '{subscriber}'?"
+                ):
                     bug.subscribe(person=lp.people[subscriber])
                 else:
                     result = False
     else:
-        if 'oem-solutions-engineers' not in subscriptions:
+        if "oem-solutions-engineers" not in subscriptions:
             error(f"'oem-solutions-engineers' is not in the subscriptions.")
-            if update and yes_or_ask(yes, f"Do you want to subscribe 'oem-solutions-engineers'?"):
+            if update and yes_or_ask(
+                yes, f"Do you want to subscribe 'oem-solutions-engineers'?"
+            ):
                 bug.subscribe(person=lp.people[subscriber])
             else:
                 result = False
@@ -573,13 +692,15 @@ def check_bug_tags(bug) -> bool:
 
 def _run_command(command: list or tuple, returncode=(0,), env=None) -> (str, str):
     debug("$ " + " ".join(command))
-    proc = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
+    proc = subprocess.Popen(
+        command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env
+    )
     out, err = proc.communicate()
 
     if out:
-        out = out.decode('utf-8').strip()
+        out = out.decode("utf-8").strip()
     if err:
-        err = err.decode('utf-8').strip()
+        err = err.decode("utf-8").strip()
 
     if proc.returncode not in returncode:
         critical(f"return {proc.returncode}")
@@ -597,7 +718,9 @@ def _run_command(command: list or tuple, returncode=(0,), env=None) -> (str, str
     return (out, err, proc.returncode)
 
 
-def check_and_update_bug_attachments(bug, pkg_name: str, update=False, yes=False) -> bool:
+def check_and_update_bug_attachments(
+    bug, pkg_name: str, update=False, yes=False
+) -> bool:
     if update:
         info("Checking and updating attachments...")
     else:
@@ -608,8 +731,8 @@ def check_and_update_bug_attachments(bug, pkg_name: str, update=False, yes=False
         critical(f"{pkg_name} failed.")
         exit(1)
 
-    if '.' in result.group(1):
-        project, group = result.group(1).split('.')
+    if "." in result.group(1):
+        project, group = result.group(1).split(".")
     else:
         project = result.group(1)
         group = None
@@ -620,7 +743,16 @@ def check_and_update_bug_attachments(bug, pkg_name: str, update=False, yes=False
     else:
         branch = f"{platform}-focal-ubuntu"
 
-    git_command = ("git", "clone", "--depth", "1", "-b", branch, f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta", pkg_name)
+    git_command = (
+        "git",
+        "clone",
+        "--depth",
+        "1",
+        "-b",
+        branch,
+        f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta",
+        pkg_name,
+    )
 
     debdiff = None
     content = None
@@ -628,33 +760,49 @@ def check_and_update_bug_attachments(bug, pkg_name: str, update=False, yes=False
 
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
-        _run_command(['wget', 'https://bazaar.launchpad.net/~ubuntu-archive/ubuntu-archive-tools/trunk/download/head:/oem-metapackage-mir-check'])
+        _run_command(
+            [
+                "wget",
+                "https://bazaar.launchpad.net/~ubuntu-archive/ubuntu-archive-tools/trunk/download/head:/oem-metapackage-mir-check",
+            ]
+        )
         _run_command(git_command)
         git_dir = os.path.join(tmpdir, pkg_name)
         os.chdir(git_dir)
-        _run_command(['dpkg-buildpackage', '-S', '-us', '-uc'])
+        _run_command(["dpkg-buildpackage", "-S", "-us", "-uc"])
         os.chdir(tmpdir)
-        dsc = glob(f'{pkg_name}*.dsc')[0]
-        prog = re.compile(fr'{pkg_name}_(.*).dsc')
+        dsc = glob(f"{pkg_name}*.dsc")[0]
+        prog = re.compile(fr"{pkg_name}_(.*).dsc")
         result = prog.match(dsc)
         version = result.group(1)
         debdiff = f"{pkg_name}_{version}.debdiff"
         # It should generate some debdiff so the return code should be 1 unless comparing to oem-qemu-meta itself.
         debug(f"TZ={args.tz}")
-        content, _, _ = _run_command(['bash', 'oem-metapackage-mir-check', dsc], returncode=(1,), env=dict(os.environ, TZ=args.tz))
+        content, _, _ = _run_command(
+            ["bash", "oem-metapackage-mir-check", dsc],
+            returncode=(1,),
+            env=dict(os.environ, TZ=args.tz),
+        )
         content += "\n"
-        with open(debdiff, 'w') as f:
+        with open(debdiff, "w") as f:
             f.write(content)
 
         for attachment in bug.attachments:
-            if 'debdiff' in attachment.title:
-                _run_command(['wget', attachment.data_link, '-O', 'data'])
-                out, err, returncode = _run_command(['colordiff', '-ur', 'data', debdiff], returncode=(0, 1))
+            if "debdiff" in attachment.title:
+                _run_command(["wget", attachment.data_link, "-O", "data"])
+                out, err, returncode = _run_command(
+                    ["colordiff", "-ur", "data", debdiff], returncode=(0, 1)
+                )
                 if returncode == 1:
-                    warning(f"{attachment.title} - {attachment.web_link} has unexpected content.")
+                    warning(
+                        f"{attachment.title} - {attachment.web_link} has unexpected content."
+                    )
                     info(f"{out}")
                     found = True
-                    if update and yes_or_ask(yes, f"Do you want to remove {attachment.title} - {attachment.web_link}?"):
+                    if update and yes_or_ask(
+                        yes,
+                        f"Do you want to remove {attachment.title} - {attachment.web_link}?",
+                    ):
                         try:
                             attachment.removeFromBug()
                         except lazr.restfulclient.errors.NotFound as e:
@@ -669,32 +817,54 @@ def check_and_update_bug_attachments(bug, pkg_name: str, update=False, yes=False
         error(f"There is no {debdiff}.")
     info(content)
     if update and yes_or_ask(yes, f"Do you want to attach {debdiff}?"):
-        bug.addAttachment(filename=debdiff, data=content.encode("utf-8"), comment=f"Attach {debdiff} by oem-scripts {oem_scripts.__version__:.2f}.", is_patch=True)
+        bug.addAttachment(
+            filename=debdiff,
+            data=content.encode("utf-8"),
+            comment=f"Attach {debdiff} by oem-scripts {oem_scripts.__version__:.2f}.",
+            is_patch=True,
+        )
         return True
     else:
         return False
 
 
 def _get_items_from_git(project: str, branch: str, pkg_name: str) -> tuple:
-    git_command = ("git", "clone", "--depth", "1", "-b", branch, f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta", pkg_name)
+    git_command = (
+        "git",
+        "clone",
+        "--depth",
+        "1",
+        "-b",
+        branch,
+        f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta",
+        pkg_name,
+    )
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
         _run_command(git_command)
         git_dir = os.path.join(tmpdir, pkg_name)
 
-        if project == 'somerville':
-            prog = re.compile(r"alias pci:\*sv00001028sd0000([0-9A-F]{4})[^ ]* meta (.*)")
-        elif project == 'stella':
-            prog = re.compile(r"alias pci:\*sv0000103Csd0000([0-9A-F]{4})[^ ]* meta (.*)")
+        if project == "somerville":
+            prog = re.compile(
+                r"alias pci:\*sv00001028sd0000([0-9A-F]{4})[^ ]* meta (.*)"
+            )
+        elif project == "stella":
+            prog = re.compile(
+                r"alias pci:\*sv0000103Csd0000([0-9A-F]{4})[^ ]* meta (.*)"
+            )
         else:
-            prog = re.compile(r"alias dmi:\*bvn([0-9a-zA-Z]+):bvr([0-9a-zA-Z]{3})\* meta (.*)")
+            prog = re.compile(
+                r"alias dmi:\*bvn([0-9a-zA-Z]+):bvr([0-9a-zA-Z]{3})\* meta (.*)"
+            )
 
         ids = []
-        with open(os.path.join(git_dir, 'debian', 'modaliases'), 'r') as modaliases:
+        with open(os.path.join(git_dir, "debian", "modaliases"), "r") as modaliases:
             for line in modaliases:
                 result = prog.match(line.strip())
                 if result.group(result.lastindex) != pkg_name:
-                    error("Something wrong in debian/modaliases. Please fix it manually first.")
+                    error(
+                        "Something wrong in debian/modaliases. Please fix it manually first."
+                    )
                     return False
                 if result.lastindex == 3:
                     ids.append((result.group(1), result.group(2)))
@@ -702,21 +872,25 @@ def _get_items_from_git(project: str, branch: str, pkg_name: str) -> tuple:
                     ids.append(result.group(1))
         kernel_flavour = None
         kernel_meta = None
-        with open(os.path.join(git_dir, 'debian', 'control'), 'r') as control:
+        with open(os.path.join(git_dir, "debian", "control"), "r") as control:
             for line in control:
-                if line.startswith('XB-Ubuntu-OEM-Kernel-Flavour:'):
-                    kernel_flavour = line[len('XB-Ubuntu-OEM-Kernel-Flavour:'):].strip()
-                elif line.startswith('Depends:'):
-                    if 'linux-oem-20.04b' in line:
-                        kernel_meta = 'linux-oem-20.04b'
-                    elif 'linux-oem-20.04' in line:
-                        kernel_meta = 'linux-oem-20.04'
-                    elif 'linux-generic-hwe-20.04' in line:
-                        kernel_meta = 'linux-generic-hwe-20.04'
+                if line.startswith("XB-Ubuntu-OEM-Kernel-Flavour:"):
+                    kernel_flavour = line[
+                        len("XB-Ubuntu-OEM-Kernel-Flavour:") :
+                    ].strip()
+                elif line.startswith("Depends:"):
+                    if "linux-oem-20.04b" in line:
+                        kernel_meta = "linux-oem-20.04b"
+                    elif "linux-oem-20.04" in line:
+                        kernel_meta = "linux-oem-20.04"
+                    elif "linux-generic-hwe-20.04" in line:
+                        kernel_meta = "linux-generic-hwe-20.04"
         return kernel_flavour, kernel_meta, ids
 
 
-def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, update=False, username=None) -> bool:
+def check_and_update_git_repo(
+    bug, pkg_name: str, yes=False, bootstrap=True, update=False, username=None
+) -> bool:
     if update:
         if bootstrap:
             info("Checking and updating git repo for bootstrap branch...")
@@ -734,17 +908,17 @@ def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, upd
         critical(f"{pkg_name} failed.")
         exit(1)
 
-    if '.' in result.group(1):
-        project, group = result.group(1).split('.')
+    if "." in result.group(1):
+        project, group = result.group(1).split(".")
     else:
         project = result.group(1)
         group = None
     platform = result.group(2)
 
     if bootstrap:
-        suffix = 'ubuntu'
+        suffix = "ubuntu"
     else:
-        suffix = 'oem'
+        suffix = "oem"
 
     if group:
         branch = f"{group}.{platform}-focal-{suffix}"
@@ -752,23 +926,27 @@ def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, upd
         branch = f"{platform}-focal-{suffix}"
 
     kernel_flavour, kernel_meta, ids = _get_items_from_git(project, branch, pkg_name)
-    if kernel_flavour == 'default':
+    if kernel_flavour == "default":
         if kernel_meta is None:
-            kernel_meta = 'linux-generic-hwe-20.04'
-        elif kernel_meta == 'linux-generic-hwe-20.04':
+            kernel_meta = "linux-generic-hwe-20.04"
+        elif kernel_meta == "linux-generic-hwe-20.04":
             pass
         else:
-            critical(f"{pkg_name}'s {branch} branch has unexpected kernel_flavour=${kernel_flavour}, kernel_meta={kernel_meta}.")
+            critical(
+                f"{pkg_name}'s {branch} branch has unexpected kernel_flavour=${kernel_flavour}, kernel_meta={kernel_meta}."
+            )
             exit(1)
-    elif kernel_flavour == 'oem':
+    elif kernel_flavour == "oem":
         if kernel_meta is None:
-            kernel_meta = 'linux-oem-20.04'
-        elif kernel_meta == 'linux-oem-20.04b':
+            kernel_meta = "linux-oem-20.04"
+        elif kernel_meta == "linux-oem-20.04b":
             pass
-        elif kernel_meta == 'linux-oem-20.04':
+        elif kernel_meta == "linux-oem-20.04":
             pass
         else:
-            critical(f"{pkg_name}'s {branch} branch has unexpected kernel_flavour=${kernel_flavour}, kernel_meta={kernel_meta}.")
+            critical(
+                f"{pkg_name}'s {branch} branch has unexpected kernel_flavour=${kernel_flavour}, kernel_meta={kernel_meta}."
+            )
             exit(1)
 
     if ids == []:
@@ -778,27 +956,61 @@ def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, upd
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
         # Generated the meta package by pkg-oem-meta
-        if project == 'somerville':
-            command = ['pkg-somerville-meta', '-s', 'focal', '-k', kernel_meta, '-p', platform, '--public-bug', str(bug.id)]
+        if project == "somerville":
+            command = [
+                "pkg-somerville-meta",
+                "-s",
+                "focal",
+                "-k",
+                kernel_meta,
+                "-p",
+                platform,
+                "--public-bug",
+                str(bug.id),
+            ]
             command.extend(ids)
-        elif project == 'stella':
-            command = ['pkg-stella-meta', '-s', 'focal', '-k', kernel_meta, '-g', group, '-p', platform, '--public-bug', str(bug.id)]
+        elif project == "stella":
+            command = [
+                "pkg-stella-meta",
+                "-s",
+                "focal",
+                "-k",
+                kernel_meta,
+                "-g",
+                group,
+                "-p",
+                platform,
+                "--public-bug",
+                str(bug.id),
+            ]
             command.extend(ids)
-        elif project == 'sutton':
-            command = ['pkg-sutton-meta', '-s', 'focal', '-k', kernel_meta, '-g', group, '-p', platform, '--public-bug', str(bug.id)]
+        elif project == "sutton":
+            command = [
+                "pkg-sutton-meta",
+                "-s",
+                "focal",
+                "-k",
+                kernel_meta,
+                "-g",
+                group,
+                "-p",
+                platform,
+                "--public-bug",
+                str(bug.id),
+            ]
             for bvn, bvr in ids:
                 command.append(f"bvn{bvn}:bvr{bvr}")
         _run_command(command)
         new_dir = os.path.join(tmpdir, pkg_name)
         os.chdir(new_dir)
         if bootstrap:
-            _run_command(['git', 'checkout', branch])
+            _run_command(["git", "checkout", branch])
 
         os.chdir(tmpdir)
-        os.rename(new_dir, new_dir + '.new')
+        os.rename(new_dir, new_dir + ".new")
         new_dir += ".new"
-        shutil.rmtree(os.path.join(new_dir, '.git'))
-        os.remove(os.path.join(new_dir, 'debian', 'changelog'))
+        shutil.rmtree(os.path.join(new_dir, ".git"))
+        os.remove(os.path.join(new_dir, "debian", "changelog"))
 
         if username:
             git_repo = f"git+ssh://{username}@git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta"
@@ -811,25 +1023,27 @@ def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, upd
 
         if bootstrap:
             lines = None
-            changelog = os.path.join(tmpdir, pkg_name, 'debian', 'changelog')
-            with open(changelog, 'r') as f:
+            changelog = os.path.join(tmpdir, pkg_name, "debian", "changelog")
+            with open(changelog, "r") as f:
                 lines = f.readlines()
 
             lines[0] = f"{pkg_name} (20.04~ubuntu1) UNRELEASED; urgency=medium\n"
 
-            if f"(LP: #{bug.id})" not in lines[2] and lines[2].startswith("  * Meta package for"):
+            if f"(LP: #{bug.id})" not in lines[2] and lines[2].startswith(
+                "  * Meta package for"
+            ):
                 lines[2] = "  " + lines[2].strip() + f" (LP: #{bug.id})\n"
 
-            with open(changelog, 'w') as f:
+            with open(changelog, "w") as f:
                 f.writelines(lines)
 
         # Remove deprecated autopkgtest file
-        deprecated_test = os.path.join(tmpdir, pkg_name, 'debian', 'tests', pkg_name)
+        deprecated_test = os.path.join(tmpdir, pkg_name, "debian", "tests", pkg_name)
         if os.path.exists(deprecated_test):
             _run_command(["git", "rm", f"debian/tests/{pkg_name}"])
 
         # Remove deprecated debian/compat
-        deprecated_compat = os.path.join(tmpdir, pkg_name, 'debian', 'compat')
+        deprecated_compat = os.path.join(tmpdir, pkg_name, "debian", "compat")
         if os.path.exists(deprecated_compat):
             _run_command(["git", "rm", f"debian/compat"])
 
@@ -841,22 +1055,39 @@ def check_and_update_git_repo(bug, pkg_name: str, yes=False, bootstrap=True, upd
 
         _run_command(["git", "add", "."])
         out, _, _ = _run_command(["git", "diff", "--color=always", "--cached"])
-        if out != b'':
+        if out != b"":
             warning("$ git diff")
             print(out)
             if update is True:
                 if args.skip:
-                    warning(f"The update of the '{branch}' branch of {pkg_name}'s Git repository is skipped on demand.")
+                    warning(
+                        f"The update of the '{branch}' branch of {pkg_name}'s Git repository is skipped on demand."
+                    )
                     return False
-                elif yes_or_ask(yes, f"Do you want to commit and push the changes above into the '{branch}' branch of {pkg_name}'s Git repository?"):
-                    _run_command(['git', 'commit', '-a', '-m', f"Updated by oem-scripts {oem_scripts.__version__:.2f}."])
-                    _run_command(['git', 'push'])
+                elif yes_or_ask(
+                    yes,
+                    f"Do you want to commit and push the changes above into the '{branch}' branch of {pkg_name}'s Git repository?",
+                ):
+                    _run_command(
+                        [
+                            "git",
+                            "commit",
+                            "-a",
+                            "-m",
+                            f"Updated by oem-scripts {oem_scripts.__version__:.2f}.",
+                        ]
+                    )
+                    _run_command(["git", "push"])
                     return True
             else:
                 if bootstrap:
-                    error(f"The '{branch}' branch of {pkg_name} in Git repository needs to update.")
+                    error(
+                        f"The '{branch}' branch of {pkg_name} in Git repository needs to update."
+                    )
                 else:
-                    warning(f"The '{branch}' branch of {pkg_name} in Git repository may need to update.")
+                    warning(
+                        f"The '{branch}' branch of {pkg_name} in Git repository may need to update."
+                    )
                 return False
         else:
             info(f"The '{branch}' branch of {pkg_name} in Git repository looks fine.")
@@ -867,13 +1098,13 @@ if args.subcommand:
     login = LaunchpadLogin()
     lp = login.lp
 
-if args.subcommand == 'create':
+if args.subcommand == "create":
     create_bug(lp, args.oemCodename, args.platformCodename, args.deviceName)
-elif args.subcommand == 'update':
+elif args.subcommand == "update":
     update_bug(lp, args.bugNumber, args.yes)
-elif args.subcommand == 'check':
+elif args.subcommand == "check":
     check_bug(lp, args.bugNumber)
-elif args.subcommand == 'collect':
+elif args.subcommand == "collect":
     collect_bugs(lp, args.json)
 else:
     parser.print_help()
diff --git a/oem-getiso b/oem-getiso
index fc7723d..932e769 100755
--- a/oem-getiso
+++ b/oem-getiso
@@ -11,11 +11,10 @@ import sys
 import re
 from optparse import OptionParser
 
-__DEBUG__ = (os.getenv('DEBUG') == 'true')
+__DEBUG__ = os.getenv("DEBUG") == "true"
 
 
 class ImageURI(object):
-
     def __init__(self, project, date, buildorder, image_type):
         self.project = project
         self.date = date
@@ -24,13 +23,12 @@ class ImageURI(object):
         self.image_type = image_type
 
         # default value
-        self.siteurl = 'https://oem-share.canonical.com'
+        self.siteurl = "https://oem-share.canonical.com"
         self.ispublished = False
 
     @property
     def rootdir(self):
-        self._rootdir = self.ispublished and\
-            '/partners/' or '/oem/cesg-builds/'
+        self._rootdir = self.ispublished and "/partners/" or "/oem/cesg-builds/"
         return self._rootdir
 
     @property
@@ -44,23 +42,31 @@ class ImageURI(object):
     @property
     def imagepath(self):
         if self.ispublished:
-            return os.path.join(self.project, 'images',
-                                '{}-{}'.format(self.date, self.buildorder),
-                                self.image_type, self.isoname)
+            return os.path.join(
+                self.project,
+                "images",
+                "{}-{}".format(self.date, self.buildorder),
+                self.image_type,
+                self.isoname,
+            )
         else:
-            return os.path.join(self.project, self.date, self.buildorder,
-                                'images', self.image_type, self.isoname)
+            return os.path.join(
+                self.project,
+                self.date,
+                self.buildorder,
+                "images",
+                self.image_type,
+                self.isoname,
+            )
 
     @property
     def isoname(self):
         if self.manifest_ver:
-            project = self.project + '-' + self.manifest_ver
+            project = self.project + "-" + self.manifest_ver
         else:
             project = self.project
-        image_type = 'iso' \
-            if re.match(r'^dell-bto', self.project) else self.image_type
-        return '{}-{}-{}-{}.iso'.format(project, image_type,
-                                        self.date, self.buildorder)
+        image_type = "iso" if re.match(r"^dell-bto", self.project) else self.image_type
+        return "{}-{}-{}-{}.iso".format(project, image_type, self.date, self.buildorder)
 
     @classmethod
     def from_url(cls, url):
@@ -88,33 +94,41 @@ class ImageURI(object):
         'dell-bto-oneiric-pebble-beach-X05-iso-20111226-0.iso'
         >>> o = ImageURI.from_url('https://oem-share.canonical.com/partners/dell-bto-oneiric-audi-13-intel/images/20120316-3/iso/dell-bto-oneiric-audi-13-intel-A04-iso-20120316-3.iso')
         """
+
         def _parse(url):
             from urllib.parse import urlparse
-            if not re.match(r'^https.*', url):
-                logging.error('{0} is not a valid image URL'.format(url))
+
+            if not re.match(r"^https.*", url):
+                logging.error("{0} is not a valid image URL".format(url))
                 raise IndexError
-            comps = urlparse(url).path.split('/')
-            published = (comps[1] == 'partners')
+            comps = urlparse(url).path.split("/")
+            published = comps[1] == "partners"
             if published:
                 (proj, image_type) = (comps[2], comps[5])
-                (date, buildorder) = comps[4].split('-')
+                (date, buildorder) = comps[4].split("-")
             else:
-                (proj, date, buildorder, image_type) = \
-                    (comps[3], comps[4], comps[5], comps[7])
-            if 'dell-bto' in proj:
+                (proj, date, buildorder, image_type) = (
+                    comps[3],
+                    comps[4],
+                    comps[5],
+                    comps[7],
+                )
+            if "dell-bto" in proj:
                 manifest_ver_index = published and 6 or 8
                 try:
-                    manifest_ver = comps[manifest_ver_index].split('-')[-4]
+                    manifest_ver = comps[manifest_ver_index].split("-")[-4]
                 except IndexError:
-                    logging.error('published:{0} manifest_ver_index:{1}'
-                                  .format(published, manifest_ver_index))
+                    logging.error(
+                        "published:{0} manifest_ver_index:{1}".format(
+                            published, manifest_ver_index
+                        )
+                    )
                     raise IndexError
             else:
                 manifest_ver = None
-            return (proj, date, buildorder, published,
-                    manifest_ver, image_type)
-        (project, date, buildorder, published, manifest_ver, image_type) = \
-            _parse(url)
+            return (proj, date, buildorder, published, manifest_ver, image_type)
+
+        (project, date, buildorder, published, manifest_ver, image_type) = _parse(url)
         obj = cls(project, date, buildorder, image_type)
         obj.manifest_ver = manifest_ver
         obj.ispublished = published
@@ -141,25 +155,24 @@ class ImageURI(object):
 
 def __testself():
     import doctest
+
     doctest.testmod()
 
 
 class RsyncURI(object):
-
     def __init__(self, imguri, username=None, siteurl=None):
         self.imguri = imguri
-        self.siteurl = siteurl or 'oem-share.canonical.com'
-        self.username = username or os.getenv('USER')
-        self.rootdir = '/srv/oem-share.canonical.com/www'
+        self.siteurl = siteurl or "oem-share.canonical.com"
+        self.username = username or os.getenv("USER")
+        self.rootdir = "/srv/oem-share.canonical.com/www"
 
     @property
     def isolink(self):
-        return '{}@{}:{}'.format(self.username, self.siteurl, self.imagepath)
+        return "{}@{}:{}".format(self.username, self.siteurl, self.imagepath)
 
     @property
     def imagepath(self):
-        return self.rootdir + os.path.join(self.imguri.rootdir,
-                                           self.imguri.imagepath)
+        return self.rootdir + os.path.join(self.imguri.rootdir, self.imguri.imagepath)
 
     @classmethod
     def from_imguri(cls, imguri):
@@ -176,7 +189,6 @@ class RsyncURI(object):
 
 
 class _Downloader(object):
-
     def __init__(self, url):
         """
         >>> o = _Downloader('https://oem-share.canonical.com/partners/somerville-oneiric-amd64/images/20111116-1/iso/somerville-oneiric-amd64-iso-20111116-1.iso')
@@ -185,8 +197,7 @@ class _Downloader(object):
         self.imguri = ImageURI.from_url(url)
 
     def find_lastdownloadediso(self):
-        proj_isos = filter(lambda iso: self.imguri.project in iso,
-                           glob.glob('*.iso'))
+        proj_isos = filter(lambda iso: self.imguri.project in iso, glob.glob("*.iso"))
         try:
             return sorted_isos(proj_isos)[-1]
         except IndexError:
@@ -205,12 +216,12 @@ class _Downloader(object):
 
     def run(self):
         self.lastiso = self.find_lastdownloadediso()
-        print('Found last downloaded file:{}'.format(self.lastiso))
+        print("Found last downloaded file:{}".format(self.lastiso))
         self.isolink = RsyncURI.from_imguri(self.imguri).isolink
         # if os.path.exists(self.imguri.isoname):
         #     sys.exit("Image {} already be downloaded.".format(
         #         self.imguri.isoname))
-        print('Starting to download file:{}'.format(self.imguri.isoname))
+        print("Starting to download file:{}".format(self.imguri.isoname))
         self.proc = self.do_download()
         ret = self.proc.wait()
         self.post_download()
@@ -222,10 +233,7 @@ class RsyncDownloader(_Downloader):
 
     def do_download(self):
         self.filename = self.lastiso and self.lastiso or self.imguri.isoname
-        cmd = ['rsync', '-Pv',
-               self.isolink,
-               self.filename
-               ]
+        cmd = ["rsync", "-Pv", self.isolink, self.filename]
 
         return subprocess.Popen(cmd)
 
@@ -235,24 +243,27 @@ class RsyncDownloader(_Downloader):
 
 
 class ZsyncDownloader(_Downloader):
-
     def __init__(self, url, auth_token):
         super(ZsyncDownloader, self).__init__(url)
         self.auth_token = auth_token
 
     def do_download(self):
-        cmd = ['zsync_curl',
-               self.imguri.isolink + '.zsync',
-               '-c pysid=' + self.auth_token
-               ]
+        cmd = [
+            "zsync_curl",
+            self.imguri.isolink + ".zsync",
+            "-c pysid=" + self.auth_token,
+        ]
         if self.lastiso:
-            cmd.append('-i ' + self.lastiso)
+            cmd.append("-i " + self.lastiso)
 
         return subprocess.Popen(" ".join(cmd), shell=True)
 
     def post_download(self):
-        if self.lastiso and self.lastiso != self.imguri.isoname and \
-           os.path.exists(self.lastiso):
+        if (
+            self.lastiso
+            and self.lastiso != self.imguri.isoname
+            and os.path.exists(self.lastiso)
+        ):
             os.remove(self.lastiso)
         if os.path.exists(self.imguri.isoname + ".zs-old"):
             os.remove(self.imguri.isoname + ".zs-old")
@@ -267,19 +278,21 @@ def sorted_isos(isos):
     >>> sorted_isos(isos)
     ['watauga2-precise-amd64-norecovery-iso-20130121-0.iso', 'watauga2-precise-amd64-norecovery-iso-20130121-1.iso']
     """
+
     def _f(e):
-        e = e.replace('.iso', '')
-        if e.startswith('dell'):
-            e = e.replace('dell-bto-oneiric-', '')
-            comps = e.split('-iso-')
-            comps = comps[1].split('-')
+        e = e.replace(".iso", "")
+        if e.startswith("dell"):
+            e = e.replace("dell-bto-oneiric-", "")
+            comps = e.split("-iso-")
+            comps = comps[1].split("-")
             (date, order) = (comps[0], comps[1])
         else:
             # Date and build number are guaranteed to be the last 2 fields
             # in the name of an ISO produced by Offspring
-            comps = e.rsplit('-', 2)
+            comps = e.rsplit("-", 2)
             (date, order) = (comps[1], comps[2])
-        return int('{}{}'.format(date, order))
+        return int("{}{}".format(date, order))
+
     return sorted(isos, key=_f)
 
 
@@ -289,7 +302,8 @@ def iso_of_bugdesc(desc):
     ('somerville-oneiric-amd64', '20111116', '1')
     """
     import re
-    ret = re.findall('Image:\\s+((\\S+)-(\\d+)-(\\d)).*', desc)
+
+    ret = re.findall("Image:\\s+((\\S+)-(\\d+)-(\\d)).*", desc)
     if ret:
         return (ret[0][1], ret[0][2], ret[0][3])
     else:
@@ -302,9 +316,10 @@ def isourl_of_bug(q):
     'https://oem-share.canonical.com/oem/cesg-builds/stella-anaheim-precise-amd64/20130116/0/images/iso/stella-anaheim-precise-amd64-iso-20130116-0.iso'
     """
     from launchpadlib.launchpad import Launchpad
+
     cachedir = os.path.join(os.environ["HOME"], ".launchpadlib/cache")
     try:
-        lp = Launchpad.login_with("oem-getiso", 'production', cachedir)
+        lp = Launchpad.login_with("oem-getiso", "production", cachedir)
         found_iso = iso_of_bugdesc(lp.bugs[q].description)
     except KeyboardInterrupt:
         print("Terminated by user reqeust!")
@@ -317,20 +332,29 @@ def isourl_of_bug(q):
     return img.isolink
 
 
-if __name__ == '__main__':
-    usage = "usage: %prog --method [rsync|zsync --auth_token " \
-            "<auth_token>] iso_url|bug_number"
+if __name__ == "__main__":
+    usage = (
+        "usage: %prog --method [rsync|zsync --auth_token "
+        "<auth_token>] iso_url|bug_number"
+    )
     parser = OptionParser(usage=usage)
     parser.add_option(
-        "--method", dest="method", default="rsync", metavar="METHOD",
-        help="The METHOD of download.  Defaults to 'rsync'.")
+        "--method",
+        dest="method",
+        default="rsync",
+        metavar="METHOD",
+        help="The METHOD of download.  Defaults to 'rsync'.",
+    )
     parser.add_option(
-        "--auth_token", dest="auth_token", metavar="AUTH_TOKEN",
-        help="The authetication token needed to access oem-share.")
+        "--auth_token",
+        dest="auth_token",
+        metavar="AUTH_TOKEN",
+        help="The authetication token needed to access oem-share.",
+    )
     (options, args) = parser.parse_args()
 
     if __DEBUG__:
-        print('self testing...')
+        print("self testing...")
         __testself()
         sys.exit()
 
@@ -353,8 +377,7 @@ if __name__ == '__main__':
         if options.auth_token is None:
             sys.exit(parser.get_usage())
         if not os.path.exists("/usr/bin/zsync_curl"):
-            sys.exit(
-                "The zync-curl package must be installed to use this method.")
+            sys.exit("The zync-curl package must be installed to use this method.")
         runner = ZsyncDownloader(url, options.auth_token)
     else:
         sys.exit(parser.get_usage())
diff --git a/oem-meta-packages b/oem-meta-packages
index 91b07ef..c98dee8 100755
--- a/oem-meta-packages
+++ b/oem-meta-packages
@@ -40,7 +40,8 @@ from string import Template
 from tempfile import TemporaryDirectory
 
 
-staging_copy_template = Template(f'''Operation: copy_package
+staging_copy_template = Template(
+    f'''Operation: copy_package
 Source: $source
 Destination: $destination
 Package: $packages
@@ -60,7 +61,8 @@ And then verify the production archive.
 """
 deb http://oem.archive.canonical.com $distribution $component
 deb-src http://oem.archive.canonical.com $distribution $component
-"""''')
+"""'''
+)
 
 
 class DataJSONEncoder(json.JSONEncoder):
@@ -90,10 +92,11 @@ class PkgInfo:
     proposed_version: str
 
 
-pattern = re.compile(r'oem-([^-]*)-(.*)-meta')
-staging_pattern = re.compile(r'.*>(.*)/</a>')
-parser = argparse.ArgumentParser(formatter_class=argparse.RawDescriptionHelpFormatter,
-                                 epilog="""
+pattern = re.compile(r"oem-([^-]*)-(.*)-meta")
+staging_pattern = re.compile(r".*>(.*)/</a>")
+parser = argparse.ArgumentParser(
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 You need to have the [oem-scripts] section in ~/.config/oem-scripts/config.ini.
 Executing `launchpad-api get people/+me` will generate it.
 
@@ -113,35 +116,38 @@ url = SomewhereToProvideTheInformationForUsernameAndPassword
 username = UserName
 password = PassWord
 archive = https://cesg.canonical.com/canonical
-fingerprint = 54F1860295829CE3""")
-
-
-parser.add_argument("-d", "--debug",
-                    help="print debug messages", action="store_true")
-parser.add_argument("-q", "--quiet",
-                    help="Don't print info messages", action="store_true")
-parser.add_argument("-v", "--verbose", action="store_true",
-                    help="print verbose messages")
-parser.add_argument("--dry-run",
-                    help="Dry run the process.", action="store_true")
-parser.add_argument("--yes",
-                    help="Say yes for all prompts.", action="store_true")
-parser.add_argument("--skip",
-                    help="Skip some projects or some meta packages.", type=str, default="")
-parser.add_argument("--only",
-                    help="Specified the meta package. Skip others.", type=str)
-parser.add_argument("--since",
-                    help="Begin from the specified meta package. Skip previous meta packages.", type=str)
-parser.add_argument("--apt-dir",
-                    type=str,
-                    help="specify the dir for apt")
+fingerprint = 54F1860295829CE3""",
+)
+
+
+parser.add_argument("-d", "--debug", help="print debug messages", action="store_true")
+parser.add_argument(
+    "-q", "--quiet", help="Don't print info messages", action="store_true"
+)
+parser.add_argument(
+    "-v", "--verbose", action="store_true", help="print verbose messages"
+)
+parser.add_argument("--dry-run", help="Dry run the process.", action="store_true")
+parser.add_argument("--yes", help="Say yes for all prompts.", action="store_true")
+parser.add_argument(
+    "--skip", help="Skip some projects or some meta packages.", type=str, default=""
+)
+parser.add_argument("--only", help="Specified the meta package. Skip others.", type=str)
+parser.add_argument(
+    "--since",
+    help="Begin from the specified meta package. Skip previous meta packages.",
+    type=str,
+)
+parser.add_argument("--apt-dir", type=str, help="specify the dir for apt")
 
 
 subparsers = parser.add_subparsers(dest="subcommand")
 
-collect = subparsers.add_parser('collect', help='[-h] --json platforms.json | --meta oem-qemu-meta -o|--output meta-info.json',
-                                formatter_class=argparse.RawDescriptionHelpFormatter,
-                                epilog="""
+collect = subparsers.add_parser(
+    "collect",
+    help="[-h] --json platforms.json | --meta oem-qemu-meta -o|--output meta-info.json",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 For example,
     oem-meta-packages collect --json platforms.json --output meta-info.json
 
@@ -179,24 +185,37 @@ platforms.json:
 
 oem-meta-packages collect --meta oem-qemu-meta --output meta-info.json
 
-Collect the information of OEM metapackages in PPAs and devel/staging archives.""")
-
-collect.add_argument("--json",
-                     help="Specify the json file to read the platforms information.",
-                     type=argparse.FileType('r', encoding='UTF-8'))
-collect.add_argument("--meta",
-                     help="Specify the meta package to collect the information.")
-collect.add_argument("-o", "--output", required=True,
-                     help="Specify a filename to write the meta information.",
-                     type=argparse.FileType('w', encoding='UTF-8'))
-
-list_pkg = subparsers.add_parser('list', help='[-h]',
-                                 formatter_class=argparse.RawDescriptionHelpFormatter,
-                                 epilog="List all OEM meta packages in Ubuntu archive.")
-
-subscribe = subparsers.add_parser('subscribe', help='[-h]',
-                                  formatter_class=argparse.RawDescriptionHelpFormatter,
-                                  epilog="""
+Collect the information of OEM metapackages in PPAs and devel/staging archives.""",
+)
+
+collect.add_argument(
+    "--json",
+    help="Specify the json file to read the platforms information.",
+    type=argparse.FileType("r", encoding="UTF-8"),
+)
+collect.add_argument(
+    "--meta", help="Specify the meta package to collect the information."
+)
+collect.add_argument(
+    "-o",
+    "--output",
+    required=True,
+    help="Specify a filename to write the meta information.",
+    type=argparse.FileType("w", encoding="UTF-8"),
+)
+
+list_pkg = subparsers.add_parser(
+    "list",
+    help="[-h]",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="List all OEM meta packages in Ubuntu archive.",
+)
+
+subscribe = subparsers.add_parser(
+    "subscribe",
+    help="[-h]",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 Make all bugs of all oem meta packages be subscribed by oem-solutions-engineers.
  (search current apt source for package lists)
 
@@ -205,56 +224,81 @@ Make all bugs of all oem meta packages be subscribed by oem-solutions-engineers.
  (search current apt source for package lists)
 
 Check "To all bugs in oem-qemu-meta in Ubuntu:" on https://launchpad.net/ubuntu/+source/oem-qemu-meta/+subscribe for example.
-""")
-
-unsubscribe = subparsers.add_parser('unsubscribe', help='[-h] pkgName',
-                                    formatter_class=argparse.RawDescriptionHelpFormatter,
-                                    epilog="""
+""",
+)
+
+unsubscribe = subparsers.add_parser(
+    "unsubscribe",
+    help="[-h] pkgName",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 Unsubscribe oem-solutions-engineers from oem-qemu-meta
 
 For example,
     oem-meta-packages unsubscribe oem-qemu-meta
-""")
-unsubscribe.add_argument("pkgName", type=str,
-                         help="Specify the package name to unsubscribe.")
-
-staging_copy = subparsers.add_parser('staging-copy', help='[-h] [--ignore-staging-lock] --json meta-info.json | --meta oem-qemu-meta',
-                                     formatter_class=argparse.RawDescriptionHelpFormatter,
-                                     epilog="""
+""",
+)
+unsubscribe.add_argument(
+    "pkgName", type=str, help="Specify the package name to unsubscribe."
+)
+
+staging_copy = subparsers.add_parser(
+    "staging-copy",
+    help="[-h] [--ignore-staging-lock] --json meta-info.json | --meta oem-qemu-meta",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 For example,
     oem-meta-packages --dry-run staging-copy --meta oem-qemu-meta
     or
     oem-meta-packages --dry-run staging-copy --json meta-info.json (generated by the 'collect' subcommand.)
 
-Copy the meta package from the devel archive into the staging archive.""")
-
-staging_copy.add_argument("--json",
-                          help="Specify the json file to read the meta information.",
-                          type=argparse.FileType('r', encoding='UTF-8'))
-staging_copy.add_argument("--meta",
-                          help="Specify the meta package to copy.")
-staging_copy.add_argument("--ignore-staging-lock",
-                          help="Ignore the staging-lock tag.", action="store_true")
-
-update = subparsers.add_parser('update', help='[-h] [--autopkgtest] --json meta-info.json | --meta oem-qemu-meta',
-                               formatter_class=argparse.RawDescriptionHelpFormatter,
-                               epilog="""
+Copy the meta package from the devel archive into the staging archive.""",
+)
+
+staging_copy.add_argument(
+    "--json",
+    help="Specify the json file to read the meta information.",
+    type=argparse.FileType("r", encoding="UTF-8"),
+)
+staging_copy.add_argument("--meta", help="Specify the meta package to copy.")
+staging_copy.add_argument(
+    "--ignore-staging-lock", help="Ignore the staging-lock tag.", action="store_true"
+)
+
+update = subparsers.add_parser(
+    "update",
+    help="[-h] [--autopkgtest] --json meta-info.json | --meta oem-qemu-meta",
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 For example,
     oem-meta-packages --dry-run update --meta oem-qemu-meta --kernel linux-oem-20.04
     or
     oem-meta-packages --dry-run update --json meta-info.json (generated by the 'collect' subcommand.)
 
-Update the market name and the kernel flavour of the OEM meta package to the default kernel flavour, i.e. linux-generic-hwe-20.04.""")
-update.add_argument("--autopkgtest", action="store_true",
-                    help="Run autopkgtest when checking the git repository.")
-update.add_argument("--json", type=argparse.FileType('r', encoding='UTF-8'),
-                    help="Specify the json file to read the meta information.")
-update.add_argument("--meta", type=str,
-                    help="Specify the meta package to update.")
-update.add_argument("--kernel", type=str, default="linux-generic-hwe-20.04",
-                    help="Specify the kernel meta to update. linux-generic-hwe-20.04|linux-oem-20.04b|linux-oem-20.04")
-update.add_argument("--factory", action="store_true",
-                    help="Make the factory meta to depend on the kernel meta directly.")
+Update the market name and the kernel flavour of the OEM meta package to the default kernel flavour, i.e. linux-generic-hwe-20.04.""",
+)
+update.add_argument(
+    "--autopkgtest",
+    action="store_true",
+    help="Run autopkgtest when checking the git repository.",
+)
+update.add_argument(
+    "--json",
+    type=argparse.FileType("r", encoding="UTF-8"),
+    help="Specify the json file to read the meta information.",
+)
+update.add_argument("--meta", type=str, help="Specify the meta package to update.")
+update.add_argument(
+    "--kernel",
+    type=str,
+    default="linux-generic-hwe-20.04",
+    help="Specify the kernel meta to update. linux-generic-hwe-20.04|linux-oem-20.04b|linux-oem-20.04",
+)
+update.add_argument(
+    "--factory",
+    action="store_true",
+    help="Make the factory meta to depend on the kernel meta directly.",
+)
 
 args = parser.parse_args()
 
@@ -263,18 +307,20 @@ setup_logging(debug=args.debug, quiet=args.quiet)
 if args.subcommand:
     login = LaunchpadLogin()
     lp = login.lp
-    oem_archive = lp.people['oem-archive']
+    oem_archive = lp.people["oem-archive"]
 
 if args.apt_dir:
     apt_pkg.init_config()
     if args.debug:
         old = apt_pkg.config.dump()
     apt_pkg.config.set("Dir", args.apt_dir)
-    apt_pkg.config.set("Dir::State::status", os.path.join(args.apt_dir, "var/lib/dpkg/status"))
+    apt_pkg.config.set(
+        "Dir::State::status", os.path.join(args.apt_dir, "var/lib/dpkg/status")
+    )
     if args.debug:
         new = apt_pkg.config.dump()
         d = difflib.Differ()
-        diff = d.compare(old.split('\n'), new.split('\n'))
+        diff = d.compare(old.split("\n"), new.split("\n"))
         for line in diff:
             debug(line.strip())
     apt_pkg.init_system()
@@ -288,7 +334,7 @@ def yes_or_ask(yes: bool, message: str) -> bool:
         res = input(f"> \033[1;34m{message}\033[1;0m (y/n) ").lower()
         if res not in {"y", "n"}:
             continue
-        if res == 'y':
+        if res == "y":
             return True
         else:
             return False
@@ -302,21 +348,25 @@ def _debug_obj(pkg) -> None:
     debug(dir(pkg))
 
     for attr in dir(pkg):
-        if not attr.startswith('__'):
+        if not attr.startswith("__"):
             if not isinstance(pkg.__getattribute__(attr), types.BuiltinFunctionType):
                 debug(f"{attr}: {pkg.__getattribute__(attr)}")
 
 
-def _run_command(command: list or tuple, returncode=(0,), env=None, silent=False) -> (str, str, int):
+def _run_command(
+    command: list or tuple, returncode=(0,), env=None, silent=False
+) -> (str, str, int):
     if not silent:
         debug("$ " + " ".join(command))
-    proc = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
+    proc = subprocess.Popen(
+        command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env
+    )
     out, err = proc.communicate()
 
     if out:
-        out = out.decode('utf-8').strip()
+        out = out.decode("utf-8").strip()
     if err:
-        err = err.decode('utf-8').strip()
+        err = err.decode("utf-8").strip()
 
     if proc.returncode not in returncode:
         critical(f"return {proc.returncode}")
@@ -339,7 +389,11 @@ def get_oem_meta_packages(cache) -> list:
     pkg_list = []
     for pkg in cache.packages:
         name = pkg.name
-        if not name.startswith('oem-') or not name.endswith('-meta') or '-factory-' in name:
+        if (
+            not name.startswith("oem-")
+            or not name.endswith("-meta")
+            or "-factory-" in name
+        ):
             continue
         pkg_list.append(name)
     return sorted(pkg_list)
@@ -347,8 +401,8 @@ def get_oem_meta_packages(cache) -> list:
 
 def _grouping_market_names(market_names: list, maxsplit=1) -> str:
     # Remove empty item
-    while '' in market_names:
-        market_names.remove('')
+    while "" in market_names:
+        market_names.remove("")
     tmp = collections.defaultdict(list)
     space_in_model = False
     try:
@@ -356,28 +410,28 @@ def _grouping_market_names(market_names: list, maxsplit=1) -> str:
             if maxsplit == 1:
                 name, model = market_name.split(maxsplit=maxsplit)
                 tmp[name].append(model)
-                if ' ' in model:
+                if " " in model:
                     space_in_model = True
             elif maxsplit == 2:
                 brand, name, model = market_name.split(maxsplit=maxsplit)
-                tmp[brand + ' ' + name].append(model)
-                if ' ' in model:
+                tmp[brand + " " + name].append(model)
+                if " " in model:
                     space_in_model = True
     except ValueError:
-        return ', '.join(sorted(market_names))
+        return ", ".join(sorted(market_names))
 
     if space_in_model:
-        return ', '.join(f"{name} {', '.join(models)}" for name, models in tmp.items())
+        return ", ".join(f"{name} {', '.join(models)}" for name, models in tmp.items())
     else:
-        return ', '.join(f"{name} {'/'.join(models)}" for name, models in tmp.items())
+        return ", ".join(f"{name} {'/'.join(models)}" for name, models in tmp.items())
 
 
 def deal_with_description(git_dir, old, new) -> bool:
     if not old or not new:
         return False
     os.chdir(git_dir)
-    file_path = os.path.join(git_dir, 'debian', 'control')
-    with open(file_path, 'r') as control:
+    file_path = os.path.join(git_dir, "debian", "control")
+    with open(file_path, "r") as control:
         lines = control.readlines()
     changed = False
     for i, line in enumerate(lines):
@@ -385,7 +439,7 @@ def deal_with_description(git_dir, old, new) -> bool:
             changed = True
             lines[i] = line.replace(old, new)
     info(f'"{old}" will be replaced by "{new}".')
-    with open(file_path, 'w') as control:
+    with open(file_path, "w") as control:
         control.writelines(lines)
     _run_command(["git", "add", "debian/control"])
     return changed
@@ -395,39 +449,41 @@ def deal_with_kernel_flavour(pkg_name, branch, git_dir) -> bool:
     os.chdir(git_dir)
     idx = -1
     kernel_flavour = None
-    file_path = os.path.join(git_dir, 'debian', 'control')
-    with open(file_path, 'r') as control:
+    file_path = os.path.join(git_dir, "debian", "control")
+    with open(file_path, "r") as control:
         lines = control.readlines()
     for i, line in enumerate(lines):
-        if line.startswith('XB-Ubuntu-OEM-Kernel-Flavour:'):
-            kernel_flavour = line[len('XB-Ubuntu-OEM-Kernel-Flavour:'):].strip()
+        if line.startswith("XB-Ubuntu-OEM-Kernel-Flavour:"):
+            kernel_flavour = line[len("XB-Ubuntu-OEM-Kernel-Flavour:") :].strip()
             idx = i
             break
 
     if not kernel_flavour:
-        critical(f"There is no XB-Ubuntu-OEM-Kernel-Flavour in debian/control of {branch} for {pkg_name}.")
+        critical(
+            f"There is no XB-Ubuntu-OEM-Kernel-Flavour in debian/control of {branch} for {pkg_name}."
+        )
         exit(1)
 
     debug(f"XB-Ubuntu-OEM-Kernel-Flavour: {kernel_flavour}")
 
-    if args.kernel == 'linux-generic-hwe-20.04':
-        if kernel_flavour == 'default':
+    if args.kernel == "linux-generic-hwe-20.04":
+        if kernel_flavour == "default":
             return False
-        kernel_flavour = 'default'
-    elif args.kernel == 'linux-oem-20.04':
-        if kernel_flavour == 'oem':
+        kernel_flavour = "default"
+    elif args.kernel == "linux-oem-20.04":
+        if kernel_flavour == "oem":
             return False
-        kernel_flavour = 'oem'
-    elif args.kernel == 'linux-oem-20.04b':
-        if kernel_flavour == 'oem':
+        kernel_flavour = "oem"
+    elif args.kernel == "linux-oem-20.04b":
+        if kernel_flavour == "oem":
             return False
-        kernel_flavour = 'oem'
+        kernel_flavour = "oem"
     else:
         print(f"{args.kernel} is not supported.")
         exit(1)
 
     lines[idx] = f"XB-Ubuntu-OEM-Kernel-Flavour: {kernel_flavour}\n"
-    with open(file_path, 'w') as control:
+    with open(file_path, "w") as control:
         control.writelines(lines)
     _run_command(["git", "add", "debian/control"])
     return True
@@ -436,12 +492,12 @@ def deal_with_kernel_flavour(pkg_name, branch, git_dir) -> bool:
 def deal_with_kernel_depends(pkg_name, branch, git_dir) -> bool:
     os.chdir(git_dir)
     idx = -1
-    file_path = os.path.join(git_dir, 'debian', 'control')
+    file_path = os.path.join(git_dir, "debian", "control")
     changed = False
-    with open(file_path, 'r') as control:
+    with open(file_path, "r") as control:
         lines = control.readlines()
     for i, line in enumerate(lines):
-        if line.startswith('Depends:'):
+        if line.startswith("Depends:"):
             idx = i
             break
 
@@ -452,24 +508,42 @@ def deal_with_kernel_depends(pkg_name, branch, git_dir) -> bool:
     debug(lines[idx].strip())
 
     # this only works for updating auto-generated code
-    if args.kernel == 'linux-generic-hwe-20.04' and ', linux-generic-hwe-20.04,' not in lines[idx]:
-        lines[idx] = lines[idx].replace(', linux-oem-20.04,', ', linux-generic-hwe-20.04,')
-        lines[idx] = lines[idx].replace(', linux-oem-20.04b | linux-oem-20.04,', ', linux-generic-hwe-20.04,')
+    if (
+        args.kernel == "linux-generic-hwe-20.04"
+        and ", linux-generic-hwe-20.04," not in lines[idx]
+    ):
+        lines[idx] = lines[idx].replace(
+            ", linux-oem-20.04,", ", linux-generic-hwe-20.04,"
+        )
+        lines[idx] = lines[idx].replace(
+            ", linux-oem-20.04b | linux-oem-20.04,", ", linux-generic-hwe-20.04,"
+        )
         changed = True
-    elif args.kernel == 'linux-oem-20.04' and ', linux-oem-20.04,' not in lines[idx]:
-        lines[idx] = lines[idx].replace(', linux-generic-hwe-20.04,', ', linux-oem-20.04,')
-        lines[idx] = lines[idx].replace(', linux-oem-20.04b | linux-oem-20.04,', ', linux-oem-20.04,')
+    elif args.kernel == "linux-oem-20.04" and ", linux-oem-20.04," not in lines[idx]:
+        lines[idx] = lines[idx].replace(
+            ", linux-generic-hwe-20.04,", ", linux-oem-20.04,"
+        )
+        lines[idx] = lines[idx].replace(
+            ", linux-oem-20.04b | linux-oem-20.04,", ", linux-oem-20.04,"
+        )
         changed = True
-    elif args.kernel == 'linux-oem-20.04b' and ', linux-oem-20.04b | linux-oem-20.04,' not in lines[idx]:
-        lines[idx] = lines[idx].replace(', linux-generic-hwe-20.04,', ', linux-oem-20.04b | linux-oem-20.04,')
-        lines[idx] = lines[idx].replace(', linux-oem-20.04,', ', linux-oem-20.04b | linux-oem-20.04,')
+    elif (
+        args.kernel == "linux-oem-20.04b"
+        and ", linux-oem-20.04b | linux-oem-20.04," not in lines[idx]
+    ):
+        lines[idx] = lines[idx].replace(
+            ", linux-generic-hwe-20.04,", ", linux-oem-20.04b | linux-oem-20.04,"
+        )
+        lines[idx] = lines[idx].replace(
+            ", linux-oem-20.04,", ", linux-oem-20.04b | linux-oem-20.04,"
+        )
         changed = True
 
     if args.factory:
         factory_idx = -1
         # Find the factory depends.
         for i, line in enumerate(lines):
-            if i > idx and line.startswith('Depends:'):
+            if i > idx and line.startswith("Depends:"):
                 factory_idx = i
                 depends_line = lines[factory_idx].strip()
                 break
@@ -478,7 +552,11 @@ def deal_with_kernel_depends(pkg_name, branch, git_dir) -> bool:
             critical("It can not find factory 'Depends' in debian/control.")
             exit(1)
 
-        for kernel in ('linux-generic-hwe-20.04', 'linux-oem-20.04', 'linux-oem-20.04b'):
+        for kernel in (
+            "linux-generic-hwe-20.04",
+            "linux-oem-20.04",
+            "linux-oem-20.04b",
+        ):
             if depends_line.endswith(kernel) or f"{kernel}," in depends_line:
                 if kernel != args.kernel:
                     lines[factory_idx] = lines[factory_idx].replace(kernel, args.kernel)
@@ -488,7 +566,7 @@ def deal_with_kernel_depends(pkg_name, branch, git_dir) -> bool:
             lines[factory_idx] = depends_line + f", {args.kernel}\n"
             changed = True
 
-    with open(file_path, 'w') as control:
+    with open(file_path, "w") as control:
         control.writelines(lines)
 
     if changed:
@@ -497,12 +575,14 @@ def deal_with_kernel_depends(pkg_name, branch, git_dir) -> bool:
     return changed
 
 
-def deal_with_debian_tests(pkg_name: str, git_dir: str, branch: str, bootstrap: bool) -> bool:
+def deal_with_debian_tests(
+    pkg_name: str, git_dir: str, branch: str, bootstrap: bool
+) -> bool:
     os.chdir(git_dir)
 
     changed = False
 
-    tests_folder = os.path.join(git_dir, 'debian', 'tests')
+    tests_folder = os.path.join(git_dir, "debian", "tests")
     if not os.path.exists(tests_folder):
         os.mkdir(tests_folder)
 
@@ -510,17 +590,17 @@ def deal_with_debian_tests(pkg_name: str, git_dir: str, branch: str, bootstrap: 
 Depends: @
 Restrictions: needs-root
 """
-    control = os.path.join(git_dir, 'debian', 'tests', 'control')
+    control = os.path.join(git_dir, "debian", "tests", "control")
 
     if os.path.exists(control):
-        with open(control, 'r') as f:
+        with open(control, "r") as f:
             if f.read() != control_content:
-                with open(control, 'w') as fp:
+                with open(control, "w") as fp:
                     fp.write(control_content)
                 _run_command(["git", "add", "debian/tests/control"])
                 changed = True
     else:
-        with open(control, 'w') as fp:
+        with open(control, "w") as fp:
             fp.write(control_content)
         _run_command(["git", "add", "debian/tests/control"])
         changed = True
@@ -538,29 +618,37 @@ apt-get update
 apt-get full-upgrade --yes
 """
     if not bootstrap:
-        if 'oem' in args.kernel:
-            grub_flavour = 'oem'
+        if "oem" in args.kernel:
+            grub_flavour = "oem"
         else:
-            grub_flavour = 'generic'
-        meta_content += '\ngrep ^GRUB_FLAVOUR_ORDER=' + grub_flavour + '$ /etc/default/grub.d/oem-flavour.cfg\n'
-        meta_content += '\ndpkg-query -W -f=\'${Status}\' ' + args.kernel + ' | grep "install ok installed"\n'
+            grub_flavour = "generic"
+        meta_content += (
+            "\ngrep ^GRUB_FLAVOUR_ORDER="
+            + grub_flavour
+            + "$ /etc/default/grub.d/oem-flavour.cfg\n"
+        )
+        meta_content += (
+            "\ndpkg-query -W -f='${Status}' "
+            + args.kernel
+            + ' | grep "install ok installed"\n'
+        )
     meta_content += f"\napt-get autoremove --purge --yes {pkg_name}\n"
-    meta = os.path.join(git_dir, 'debian', 'tests', 'meta')
-    old_meta = os.path.join(git_dir, 'debian', 'tests', pkg_name)
+    meta = os.path.join(git_dir, "debian", "tests", "meta")
+    old_meta = os.path.join(git_dir, "debian", "tests", pkg_name)
 
     if os.path.exists(old_meta):
         _run_command(["git", "rm", "-f", f"debian/tests/{pkg_name}"])
         changed = True
 
     if os.path.exists(meta):
-        with open(meta, 'r') as f:
+        with open(meta, "r") as f:
             if f.read() != meta_content:
-                with open(meta, 'w') as fp:
+                with open(meta, "w") as fp:
                     fp.write(meta_content)
                 _run_command(["git", "add", "debian/tests/meta"])
                 changed = True
     else:
-        with open(meta, 'w') as fp:
+        with open(meta, "w") as fp:
             fp.write(meta_content)
         _run_command(["git", "add", "debian/tests/meta"])
         changed = True
@@ -570,29 +658,30 @@ apt-get full-upgrade --yes
 
 def deal_with_gbp_conf(git_dir, branch) -> bool:
     os.chdir(git_dir)
-    file_path = os.path.join(git_dir, 'debian', 'gbp.conf')
+    file_path = os.path.join(git_dir, "debian", "gbp.conf")
     gbp_conf = f"""[DEFAULT]
 pristine-tar = False
 debian-branch = {branch}
 debian-tag = {branch}_%(version)s
 """
     if os.path.exists(file_path):
-        with open(file_path, 'r') as f:
+        with open(file_path, "r") as f:
             if f.read() == gbp_conf:
                 return False
-    with open(file_path, 'w') as f:
+    with open(file_path, "w") as f:
         f.write(gbp_conf)
     _run_command(["git", "add", "debian/gbp.conf"])
     return True
 
 
 def deal_with_maintainer_scripts(pkg_name, branch, git_dir) -> bool:
-    postinst_path = os.path.join(git_dir, 'debian', 'postinst')
-    postrm_path = os.path.join(git_dir, 'debian', 'postrm')
+    postinst_path = os.path.join(git_dir, "debian", "postinst")
+    postrm_path = os.path.join(git_dir, "debian", "postrm")
     modified = False
 
-    with open(postinst_path, 'w') as f:
-        f.write(f'''#!/bin/sh
+    with open(postinst_path, "w") as f:
+        f.write(
+            f"""#!/bin/sh
 
 set -e
 
@@ -609,14 +698,16 @@ case "$1" in
 esac
 
 #DEBHELPER#
-''')
+"""
+        )
     _run_command(["git", "add", "debian/postinst"])
     output, _, _ = _run_command(["git", "status", "--porcelain", "debian/postinst"])
     if output:
         modified = True
 
-    with open(postrm_path, 'w') as f:
-        f.write('''#!/bin/sh
+    with open(postrm_path, "w") as f:
+        f.write(
+            """#!/bin/sh
 
 set -e
 
@@ -632,7 +723,8 @@ case "$1" in
 esac
 
 #DEBHELPER#
-''')
+"""
+        )
     _run_command(["git", "add", "debian/postrm"])
     output, _, _ = _run_command(["git", "status", "--porcelain", "debian/postrm"])
     if output:
@@ -644,39 +736,41 @@ esac
 def deal_with_grub_flavour(pkg_name, branch, git_dir) -> bool:
     os.chdir(git_dir)
     grub_flavour = None
-    file_path = os.path.join(git_dir, 'oem-flavour.cfg')
+    file_path = os.path.join(git_dir, "oem-flavour.cfg")
     if os.path.exists(file_path):
-        with open(file_path, 'r') as oem_flavour:
+        with open(file_path, "r") as oem_flavour:
             for line in oem_flavour:
-                if line.startswith('GRUB_FLAVOUR_ORDER='):
-                    grub_flavour = line[len('GRUB_FLAVOUR_ORDER='):].strip()
+                if line.startswith("GRUB_FLAVOUR_ORDER="):
+                    grub_flavour = line[len("GRUB_FLAVOUR_ORDER=") :].strip()
                     break
 
-    if args.kernel == 'linux-generic-hwe-20.04':
-        if grub_flavour == 'generic':
+    if args.kernel == "linux-generic-hwe-20.04":
+        if grub_flavour == "generic":
             return False
-        grub_flavour = 'generic'
-    elif args.kernel == 'linux-oem-20.04':
-        if grub_flavour == 'oem':
+        grub_flavour = "generic"
+    elif args.kernel == "linux-oem-20.04":
+        if grub_flavour == "oem":
             return False
-        grub_flavour = 'oem'
-    elif args.kernel == 'linux-oem-20.04b':
-        if grub_flavour == 'oem':
+        grub_flavour = "oem"
+    elif args.kernel == "linux-oem-20.04b":
+        if grub_flavour == "oem":
             return False
-        grub_flavour = 'oem'
+        grub_flavour = "oem"
     else:
         print(f"{args.kernel} is not supported.")
         exit(1)
 
     if not os.path.exists(file_path):
-        with open(os.path.join(git_dir, 'debian', 'install'), 'a') as f:
+        with open(os.path.join(git_dir, "debian", "install"), "a") as f:
             f.write(f"oem-flavour.cfg /usr/share/{pkg_name}/\n")
         _run_command(["git", "add", "debian/install"])
 
-    with open(file_path, 'w') as f:
-        f.write(f"""# This file is automatically generated by {pkg_name}, and changes will be overriden
+    with open(file_path, "w") as f:
+        f.write(
+            f"""# This file is automatically generated by {pkg_name}, and changes will be overriden
 GRUB_FLAVOUR_ORDER={grub_flavour}
-""")
+"""
+        )
     _run_command(["git", "add", "oem-flavour.cfg"])
 
     return True
@@ -684,29 +778,31 @@ GRUB_FLAVOUR_ORDER={grub_flavour}
 
 # Python 3.9 supports this.
 def remove_prefix(s, prefix):
-    return s[len(prefix):] if s.startswith(prefix) else s
+    return s[len(prefix) :] if s.startswith(prefix) else s
 
 
 # Python 3.9 supports this.
 def remove_suffix(s, suffix):
-    return s[:-len(suffix)] if s.endswith(suffix) else s
+    return s[: -len(suffix)] if s.endswith(suffix) else s
 
 
 def remove_prefix_suffix(s, prefix, suffix):
     return remove_suffix(remove_prefix(s, prefix), suffix)
 
 
-def search_ppa_and_version(project: str, group: str, platform: str, pkg_name: str, archive_name=None):
+def search_ppa_and_version(
+    project: str, group: str, platform: str, pkg_name: str, archive_name=None
+):
     if archive_name:
         archive = oem_archive.getPPAByName(name=archive_name)
-    elif project == 'somerville':
+    elif project == "somerville":
         try:
             archive = oem_archive.getPPAByName(name=f"{project}-fossa-{platform}")
         except lazr.restfulclient.errors.NotFound:
             archive = oem_archive.getPPAByName(name=f"{project}-{platform}")
-    elif project == 'stella':
+    elif project == "stella":
         archive = oem_archive.getPPAByName(name=f"{project}-{group}-ouagadougou")
-    elif project == 'sutton':
+    elif project == "sutton":
         try:
             archive = oem_archive.getPPAByName(name=f"{project}-{group}-ouagadougou")
         except lazr.restfulclient.errors.NotFound:
@@ -718,7 +814,7 @@ def search_ppa_and_version(project: str, group: str, platform: str, pkg_name: st
             archive.newSubscription(subscriber=lp.me)
             archive.lp_save()
         except lazr.restfulclient.errors.BadRequest as e:
-            if 'already has a current subscription for' not in str(e):
+            if "already has a current subscription for" not in str(e):
                 raise e
         _run_command(["get-private-ppa", f"ppa:oem-archive/{archive.name}"])
         source_lists = "\n".join(lp.me.getArchiveSubscriptionURLs())
@@ -726,8 +822,10 @@ def search_ppa_and_version(project: str, group: str, platform: str, pkg_name: st
     fingerprint = archive.signing_key_fingerprint
     version = ""
     for source in sources:
-        if source.source_package_name == pkg_name and \
-                apt_pkg.version_compare(source.source_package_version, version) > 0:
+        if (
+            source.source_package_name == pkg_name
+            and apt_pkg.version_compare(source.source_package_version, version) > 0
+        ):
             version = source.source_package_version
     if version:
         return archive.name, version, fingerprint
@@ -741,8 +839,8 @@ def get_debian_version_from_git(pkg_name: str) -> str:
     if not result:
         return None
 
-    if '.' in result.group(1):
-        project, group = result.group(1).split('.')
+    if "." in result.group(1):
+        project, group = result.group(1).split(".")
     else:
         project = result.group(1)
         group = None
@@ -756,137 +854,215 @@ def get_debian_version_from_git(pkg_name: str) -> str:
         ubuntu_branch = f"{platform}-focal-ubuntu"
         oem_branch = f"{platform}-focal-oem"
 
-    wget_changelog_command = ("wget", '-q', "-O", "changelog",
-                              f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta/plain/debian/changelog?h={ubuntu_branch}")
+    wget_changelog_command = (
+        "wget",
+        "-q",
+        "-O",
+        "changelog",
+        f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta/plain/debian/changelog?h={ubuntu_branch}",
+    )
 
     bootstrap_version = ""
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
         _run_command(wget_changelog_command)
-        bootstrap_version, _, _ = _run_command(["dpkg-parsechangelog", "--show-field", "Version", "-l", f"changelog"])
-
-    wget_changelog_command = ("wget", '-q', "-O", "changelog",
-                              f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta/plain/debian/changelog?h={oem_branch}")
+        bootstrap_version, _, _ = _run_command(
+            ["dpkg-parsechangelog", "--show-field", "Version", "-l", f"changelog"]
+        )
+
+    wget_changelog_command = (
+        "wget",
+        "-q",
+        "-O",
+        "changelog",
+        f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta/plain/debian/changelog?h={oem_branch}",
+    )
 
     oem_version = ""
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
         _run_command(wget_changelog_command)
-        oem_version, _, _ = _run_command(["dpkg-parsechangelog", "--show-field", "Version", "-l", f"changelog"])
+        oem_version, _, _ = _run_command(
+            ["dpkg-parsechangelog", "--show-field", "Version", "-l", f"changelog"]
+        )
 
     return bootstrap_version, oem_version
 
 
 def search_public_archive(pkg_name: str, project: str, codename: str) -> tuple:
-    if project == 'somerville':
-        source_line = 'http://dell.archive.canonical.com/'
+    if project == "somerville":
+        source_line = "http://dell.archive.canonical.com/"
         archive = f"somerville-{codename}"
-    elif project == 'stella':
-        source_line = 'http://hp.archive.canonical.com/'
+    elif project == "stella":
+        source_line = "http://hp.archive.canonical.com/"
         archive = f"stella.{codename}"
-    elif project == 'sutton':
-        source_line = 'http://lenovo.archive.canonical.com/'
+    elif project == "sutton":
+        source_line = "http://lenovo.archive.canonical.com/"
         archive = f"sutton.{codename}"
     oem_version = ""
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
-        _run_command(['setup-apt-dir.sh',
-                      '-c', 'focal',
-                      '--disable-base',
-                      '--disable-updates',
-                      '--disable-backports',
-                      '--apt-dir', tmpdir,
-                      '--extra-key', '59AC787C2A8C78BA5ECA0B2ED4D1EAED36962F69',
-                      '--extra-repo', f"deb [signed-by={tmpdir}/59AC787C2A8C78BA5ECA0B2ED4D1EAED36962F69.pub arch=amd64] {source_line} focal {archive}"],
-                     silent=True)
-        output, _, _ = _run_command(['pkg-list', '--long', '--apt-dir', tmpdir, pkg_name], returncode=(0, 1), silent=True)
-        for line in output.split('\n'):
+        _run_command(
+            [
+                "setup-apt-dir.sh",
+                "-c",
+                "focal",
+                "--disable-base",
+                "--disable-updates",
+                "--disable-backports",
+                "--apt-dir",
+                tmpdir,
+                "--extra-key",
+                "59AC787C2A8C78BA5ECA0B2ED4D1EAED36962F69",
+                "--extra-repo",
+                f"deb [signed-by={tmpdir}/59AC787C2A8C78BA5ECA0B2ED4D1EAED36962F69.pub arch=amd64] {source_line} focal {archive}",
+            ],
+            silent=True,
+        )
+        output, _, _ = _run_command(
+            ["pkg-list", "--long", "--apt-dir", tmpdir, pkg_name],
+            returncode=(0, 1),
+            silent=True,
+        )
+        for line in output.split("\n"):
             if pkg_name in line and source_line in line:
-                oem_version = line.split(' ')[1]
-                info(f"{pkg_name} {oem_version} exists in 'deb {source_line} focal {archive}'.")
+                oem_version = line.split(" ")[1]
+                info(
+                    f"{pkg_name} {oem_version} exists in 'deb {source_line} focal {archive}'."
+                )
                 break
     ubuntu_version = ""
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
-        _run_command(['setup-apt-dir.sh',
-                      '-c', 'focal',
-                      '--disable-backports',
-                      '--apt-dir', tmpdir],
-                     silent=True)
-        output, _, _ = _run_command(['pkg-list', '--long', '--apt-dir', tmpdir, pkg_name], returncode=(0, 1), silent=True)
-        for line in output.split('\n'):
-            if pkg_name in line and 'http://archive.ubuntu.com/ubuntu' in line:
-                ubuntu_version = line.split(' ')[1]
+        _run_command(
+            [
+                "setup-apt-dir.sh",
+                "-c",
+                "focal",
+                "--disable-backports",
+                "--apt-dir",
+                tmpdir,
+            ],
+            silent=True,
+        )
+        output, _, _ = _run_command(
+            ["pkg-list", "--long", "--apt-dir", tmpdir, pkg_name],
+            returncode=(0, 1),
+            silent=True,
+        )
+        for line in output.split("\n"):
+            if pkg_name in line and "http://archive.ubuntu.com/ubuntu" in line:
+                ubuntu_version = line.split(" ")[1]
                 info(f"{pkg_name} {ubuntu_version} exists in Ubuntu archive.")
                 break
     proposed_version = ""
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
-        _run_command(['setup-apt-dir.sh',
-                      '-c', 'focal',
-                      '--proposed',
-                      '--disable-base',
-                      '--disable-updates',
-                      '--disable-backports',
-                      '--apt-dir', tmpdir],
-                     silent=True)
-        output, _, _ = _run_command(['pkg-list', '--long', '--apt-dir', tmpdir, pkg_name], returncode=(0, 1), silent=True)
-        for line in output.split('\n'):
-            if pkg_name in line and 'http://archive.ubuntu.com/ubuntu' in line:
-                proposed_version = line.split(' ')[1]
+        _run_command(
+            [
+                "setup-apt-dir.sh",
+                "-c",
+                "focal",
+                "--proposed",
+                "--disable-base",
+                "--disable-updates",
+                "--disable-backports",
+                "--apt-dir",
+                tmpdir,
+            ],
+            silent=True,
+        )
+        output, _, _ = _run_command(
+            ["pkg-list", "--long", "--apt-dir", tmpdir, pkg_name],
+            returncode=(0, 1),
+            silent=True,
+        )
+        for line in output.split("\n"):
+            if pkg_name in line and "http://archive.ubuntu.com/ubuntu" in line:
+                proposed_version = line.split(" ")[1]
                 info(f"{pkg_name} {proposed_version} exists in focal-proposed.")
                 break
     return ubuntu_version, proposed_version, oem_version, archive
 
 
-def search_private_archive(pkg_name: str, project: str, platform: str, index: str, config: str, branch: str) -> tuple:
-    domain = config['archive'].split("://")[1].split("/")[0]
+def search_private_archive(
+    pkg_name: str, project: str, platform: str, index: str, config: str, branch: str
+) -> tuple:
+    domain = config["archive"].split("://")[1].split("/")[0]
     archive = None
     version = None
-    for line in index.split('\n'):
-        if project in line and platform in line and f'focal-{branch}' in line:
+    for line in index.split("\n"):
+        if project in line and platform in line and f"focal-{branch}" in line:
             result = staging_pattern.match(line)
             if result:
                 archive = result.group(1)
     with TemporaryDirectory() as tmpdir:
         os.chdir(tmpdir)
-        source_line = config['archive'].replace("https://", f"https://{config['username']}:{config['password']}@")
-        _run_command(['setup-apt-dir.sh',
-                      '-c', 'focal',
-                      '--disable-updates',
-                      '--disable-backports',
-                      '--apt-dir', tmpdir,
-                      '--extra-key', config['fingerprint'],
-                      '--extra-repo', f"deb [signed-by={tmpdir}/{config['fingerprint']}.pub arch=amd64] {source_line} {archive} public"],
-                     silent=True)
-        output, _, _ = _run_command(['pkg-list', '--long', '--apt-dir', tmpdir, pkg_name], returncode=(0, 1), silent=True)
-        for line in output.split('\n'):
+        source_line = config["archive"].replace(
+            "https://", f"https://{config['username']}:{config['password']}@"
+        )
+        _run_command(
+            [
+                "setup-apt-dir.sh",
+                "-c",
+                "focal",
+                "--disable-updates",
+                "--disable-backports",
+                "--apt-dir",
+                tmpdir,
+                "--extra-key",
+                config["fingerprint"],
+                "--extra-repo",
+                f"deb [signed-by={tmpdir}/{config['fingerprint']}.pub arch=amd64] {source_line} {archive} public",
+            ],
+            silent=True,
+        )
+        output, _, _ = _run_command(
+            ["pkg-list", "--long", "--apt-dir", tmpdir, pkg_name],
+            returncode=(0, 1),
+            silent=True,
+        )
+        for line in output.split("\n"):
             if pkg_name in line and domain in line:
-                version = line.split(' ')[1]
+                version = line.split(" ")[1]
                 break
     if version is None and project == "somerville":
         archive = f"somerville-focal-{branch}"
         with TemporaryDirectory() as tmpdir:
             os.chdir(tmpdir)
-            source_line = config['archive'].replace("https://", f"https://{config['username']}:{config['password']}@")
-            _run_command(['setup-apt-dir.sh',
-                          '-c', 'focal',
-                          '--disable-updates',
-                          '--disable-backports',
-                          '--apt-dir', tmpdir,
-                          '--extra-key', config['fingerprint'],
-                          '--extra-repo', f"deb [signed-by={tmpdir}/{config['fingerprint']}.pub arch=amd64] {source_line} {archive} public"],
-                         silent=True)
-            output, _, _ = _run_command(['pkg-list', '--long', '--apt-dir', tmpdir, pkg_name], silent=True)
-            for line in output.split('\n'):
+            source_line = config["archive"].replace(
+                "https://", f"https://{config['username']}:{config['password']}@"
+            )
+            _run_command(
+                [
+                    "setup-apt-dir.sh",
+                    "-c",
+                    "focal",
+                    "--disable-updates",
+                    "--disable-backports",
+                    "--apt-dir",
+                    tmpdir,
+                    "--extra-key",
+                    config["fingerprint"],
+                    "--extra-repo",
+                    f"deb [signed-by={tmpdir}/{config['fingerprint']}.pub arch=amd64] {source_line} {archive} public",
+                ],
+                silent=True,
+            )
+            output, _, _ = _run_command(
+                ["pkg-list", "--long", "--apt-dir", tmpdir, pkg_name], silent=True
+            )
+            for line in output.split("\n"):
                 if pkg_name in line and domain in line:
-                    version = line.split(' ')[1]
+                    version = line.split(" ")[1]
                     break
 
     return (archive, version)
 
 
-def collect_pkg_info(data, check_private: bool = False, index=None, config=None) -> dict:
+def collect_pkg_info(
+    data, check_private: bool = False, index=None, config=None
+) -> dict:
     if type(data) is str:
         result = pattern.match(data)
 
@@ -894,8 +1070,8 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             print(f"{data} is not supported.")
             exit(1)
 
-        if '.' in result.group(1):
-            project, group = result.group(1).split('.')
+        if "." in result.group(1):
+            project, group = result.group(1).split(".")
         else:
             project = result.group(1)
             group = "N/A"
@@ -917,14 +1093,16 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             print(f"{data} is not supported.")
             exit(1)
 
-        json_data = json.loads(f"""[{{
+        json_data = json.loads(
+            f"""[{{
 "Customer": "{customer}",
 "Group": "{group}",
 "Codename": "{codename}",
 "Platform": "",
 "MarketName": "",
 "PlatformLPTag": "{tag}"
-}}]""")
+}}]"""
+        )
     else:
         json_data = json.load(data)
 
@@ -935,27 +1113,27 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
     sutton = dict()
 
     for item in json_data:
-        customer = item['Customer'].lower()
-        platform = item['Platform'].lower()
-        codename = item['Codename'].lower()
-        group = item['Group'].lower()
-        market_name = item['MarketName']
-        lp_tag = item['PlatformLPTag'].lower()
-        if 'dell' in customer:
-            if 'somerville' in args.skip:
+        customer = item["Customer"].lower()
+        platform = item["Platform"].lower()
+        codename = item["Codename"].lower()
+        group = item["Group"].lower()
+        market_name = item["MarketName"]
+        lp_tag = item["PlatformLPTag"].lower()
+        if "dell" in customer:
+            if "somerville" in args.skip:
                 continue
-            platform = remove_prefix(lp_tag, 'fossa-')
+            platform = remove_prefix(lp_tag, "fossa-")
             lst = somerville.get(platform, [])
             lst.append(market_name)
             somerville[platform] = lst
-        elif 'hp' in customer:
-            if 'stella' in args.skip:
+        elif "hp" in customer:
+            if "stella" in args.skip:
                 continue
             lst = stella.get(f"{group}-{codename}", [])
             lst.append(market_name)
             stella[f"{group}-{codename}"] = lst
-        elif 'lenovo' in customer:
-            if 'sutton' in args.skip:
+        elif "lenovo" in customer:
+            if "sutton" in args.skip:
                 continue
             lst = sutton.get(f"{group}-{codename}", [])
             lst.append(market_name)
@@ -975,37 +1153,58 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
         info("Finding the corresponding PPAs...")
 
     for codename, v in somerville.items():
-        pkg_name = 'oem-somerville-' + codename + '-meta'
+        pkg_name = "oem-somerville-" + codename + "-meta"
         if args.only and pkg_name != args.only:
             warning(f"Skip {pkg_name}")
             continue
         if pkg_name in args.skip:
             warning(f"Skip {pkg_name}")
             continue
-        ppa_archive, ppa_version, fingerprint = search_ppa_and_version("somerville", None, codename, pkg_name)
+        ppa_archive, ppa_version, fingerprint = search_ppa_and_version(
+            "somerville", None, codename, pkg_name
+        )
         if ppa_archive is None:
-            ppa_archive, ppa_version, fingerprint = search_ppa_and_version("somerville", None, codename, pkg_name, "somerville")
+            ppa_archive, ppa_version, fingerprint = search_ppa_and_version(
+                "somerville", None, codename, pkg_name, "somerville"
+            )
         if ppa_archive is None:
             critical(f"It can not find any private PPA that contains {pkg_name}.")
             exit(1)
 
         bootstrap_version, real_version = get_debian_version_from_git(pkg_name)
         if ppa_version != real_version:
-            warning(f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}.")
+            warning(
+                f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}."
+            )
         info(f"{pkg_name} {ppa_version} exists in ppa:oem-archive/{ppa_archive}.")
 
-        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(pkg_name, "somerville", codename)
-
-        pkgInfo[pkg_name] = PkgInfo(ppa_archive=ppa_archive, ppa_version=ppa_version,
-                                    bootstrap_version=bootstrap_version, real_version=real_version, git_version=real_version,
-                                    old_desc="", new_desc="", fingerprint=fingerprint,
-                                    staging_archive="", staging_version="",
-                                    devel_archive="", devel_version="",
-                                    oem_archive=oem_archive, oem_version=oem_version,
-                                    ubuntu_version=ubuntu_version, proposed_version=proposed_version)
+        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(
+            pkg_name, "somerville", codename
+        )
+
+        pkgInfo[pkg_name] = PkgInfo(
+            ppa_archive=ppa_archive,
+            ppa_version=ppa_version,
+            bootstrap_version=bootstrap_version,
+            real_version=real_version,
+            git_version=real_version,
+            old_desc="",
+            new_desc="",
+            fingerprint=fingerprint,
+            staging_archive="",
+            staging_version="",
+            devel_archive="",
+            devel_version="",
+            oem_archive=oem_archive,
+            oem_version=oem_version,
+            ubuntu_version=ubuntu_version,
+            proposed_version=proposed_version,
+        )
 
         if check_private:
-            staging_archive, staging_version = search_private_archive(pkg_name, "somerville", codename, index, config, branch="staging")
+            staging_archive, staging_version = search_private_archive(
+                pkg_name, "somerville", codename, index, config, branch="staging"
+            )
             pkgInfo[pkg_name].staging_archive = staging_archive
             if staging_version:
                 info(f"{pkg_name} {staging_version} exists in {staging_archive}.")
@@ -1013,7 +1212,9 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {staging_archive} yet.")
 
-            devel_archive, devel_version = search_private_archive(pkg_name, "somerville", codename, index, config, branch="devel")
+            devel_archive, devel_version = search_private_archive(
+                pkg_name, "somerville", codename, index, config, branch="devel"
+            )
             pkgInfo[pkg_name].devel_archive = devel_archive
             if devel_version:
                 info(f"{pkg_name} {devel_version} exists in {devel_archive}.")
@@ -1021,7 +1222,7 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {devel_archive} yet.")
 
-        if pkg_name in pkgNamesInArchive and ''.join(v):
+        if pkg_name in pkgNamesInArchive and "".join(v):
             new_desc = _grouping_market_names(v)
             if "Dell" not in new_desc:
                 new_desc = "Dell " + new_desc
@@ -1029,37 +1230,56 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             pkgInfo[pkg_name].new_desc = new_desc
 
     for k, v in stella.items():
-        pkg_name = 'oem-stella.' + k + '-meta'
+        pkg_name = "oem-stella." + k + "-meta"
         if args.only and pkg_name != args.only:
             warning(f"Skip {pkg_name}")
             continue
         if pkg_name in args.skip:
             warning(f"Skip {pkg_name}")
             continue
-        group, codename = k.split('-', 1)
+        group, codename = k.split("-", 1)
 
-        ppa_archive, ppa_version, fingerprint = search_ppa_and_version("stella", group, codename, pkg_name)
+        ppa_archive, ppa_version, fingerprint = search_ppa_and_version(
+            "stella", group, codename, pkg_name
+        )
         if ppa_archive is None:
             critical(f"It can not find any private PPA that contains {pkg_name}.")
             exit(1)
 
         bootstrap_version, real_version = get_debian_version_from_git(pkg_name)
         if ppa_version != real_version:
-            warning(f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}.")
+            warning(
+                f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}."
+            )
         info(f"{pkg_name} {ppa_version} exists in ppa:oem-archive/{ppa_archive}")
 
-        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(pkg_name, "stella", group)
-
-        pkgInfo[pkg_name] = PkgInfo(ppa_archive=ppa_archive, ppa_version=ppa_version,
-                                    bootstrap_version=bootstrap_version, real_version=real_version, git_version=real_version,
-                                    old_desc="", new_desc="", fingerprint=fingerprint,
-                                    staging_archive="", staging_version="",
-                                    devel_archive="", devel_version="",
-                                    oem_archive=oem_archive, oem_version=oem_version,
-                                    ubuntu_version=ubuntu_version, proposed_version=proposed_version)
+        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(
+            pkg_name, "stella", group
+        )
+
+        pkgInfo[pkg_name] = PkgInfo(
+            ppa_archive=ppa_archive,
+            ppa_version=ppa_version,
+            bootstrap_version=bootstrap_version,
+            real_version=real_version,
+            git_version=real_version,
+            old_desc="",
+            new_desc="",
+            fingerprint=fingerprint,
+            staging_archive="",
+            staging_version="",
+            devel_archive="",
+            devel_version="",
+            oem_archive=oem_archive,
+            oem_version=oem_version,
+            ubuntu_version=ubuntu_version,
+            proposed_version=proposed_version,
+        )
 
         if check_private:
-            staging_archive, staging_version = search_private_archive(pkg_name, "stella", group, index, config, branch="staging")
+            staging_archive, staging_version = search_private_archive(
+                pkg_name, "stella", group, index, config, branch="staging"
+            )
             pkgInfo[pkg_name].staging_archive = staging_archive
             if staging_version:
                 info(f"{pkg_name} {staging_version} exists in {staging_archive}.")
@@ -1067,7 +1287,9 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {staging_archive} yet.")
 
-            devel_archive, devel_version = search_private_archive(pkg_name, "stella", group, index, config, branch="devel")
+            devel_archive, devel_version = search_private_archive(
+                pkg_name, "stella", group, index, config, branch="devel"
+            )
             pkgInfo[pkg_name].devel_archive = devel_archive
             if devel_version:
                 info(f"{pkg_name} {devel_version} exists in {devel_archive}.")
@@ -1075,45 +1297,66 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {devel_archive} yet.")
 
-        if pkg_name in pkgNamesInArchive and ''.join(v):
+        if pkg_name in pkgNamesInArchive and "".join(v):
             new_desc = _grouping_market_names(v, maxsplit=2)
             if "HP" not in new_desc:
                 new_desc = "HP " + new_desc
-            pkgInfo[pkg_name].old_desc = f"Stella {group.title()} {codename.title()} platform"
+            pkgInfo[
+                pkg_name
+            ].old_desc = f"Stella {group.title()} {codename.title()} platform"
             pkgInfo[pkg_name].new_desc = new_desc
 
     for k, v in sutton.items():
-        pkg_name = 'oem-sutton.' + k + '-meta'
+        pkg_name = "oem-sutton." + k + "-meta"
         if args.only and pkg_name != args.only:
             warning(f"Skip {pkg_name}")
             continue
         if pkg_name in args.skip:
             warning(f"Skip {pkg_name}")
             continue
-        group, codename = k.split('-', 1)
+        group, codename = k.split("-", 1)
 
-        ppa_archive, ppa_version, fingerprint = search_ppa_and_version("sutton", group, codename, pkg_name)
+        ppa_archive, ppa_version, fingerprint = search_ppa_and_version(
+            "sutton", group, codename, pkg_name
+        )
         if ppa_archive is None:
             critical(f"It can not find any private PPA that contains {pkg_name}.")
             exit(1)
 
         bootstrap_version, real_version = get_debian_version_from_git(pkg_name)
         if ppa_version != real_version:
-            warning(f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}.")
+            warning(
+                f"{pkg_name}'s version in Git is {real_version}, but the version in ppa:oem-archive/{ppa_archive} is {ppa_version}."
+            )
         info(f"{pkg_name} {ppa_version} exists in ppa:oem-archive/{ppa_archive}")
 
-        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(pkg_name, "sutton", group)
-
-        pkgInfo[pkg_name] = PkgInfo(ppa_archive=ppa_archive, ppa_version=ppa_version,
-                                    bootstrap_version=bootstrap_version, real_version=real_version, git_version=real_version,
-                                    old_desc="", new_desc="", fingerprint=fingerprint,
-                                    staging_archive="", staging_version="",
-                                    devel_archive="", devel_version="",
-                                    oem_archive=oem_archive, oem_version=oem_version,
-                                    ubuntu_version=ubuntu_version, proposed_version=proposed_version)
+        ubuntu_version, proposed_version, oem_version, oem_archive = search_public_archive(
+            pkg_name, "sutton", group
+        )
+
+        pkgInfo[pkg_name] = PkgInfo(
+            ppa_archive=ppa_archive,
+            ppa_version=ppa_version,
+            bootstrap_version=bootstrap_version,
+            real_version=real_version,
+            git_version=real_version,
+            old_desc="",
+            new_desc="",
+            fingerprint=fingerprint,
+            staging_archive="",
+            staging_version="",
+            devel_archive="",
+            devel_version="",
+            oem_archive=oem_archive,
+            oem_version=oem_version,
+            ubuntu_version=ubuntu_version,
+            proposed_version=proposed_version,
+        )
 
         if check_private:
-            staging_archive, staging_version = search_private_archive(pkg_name, "sutton", group, index, config, branch="staging")
+            staging_archive, staging_version = search_private_archive(
+                pkg_name, "sutton", group, index, config, branch="staging"
+            )
             pkgInfo[pkg_name].staging_archive = staging_archive
             if staging_version:
                 info(f"{pkg_name} {staging_version} exists in {staging_archive}.")
@@ -1121,7 +1364,9 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {staging_archive} yet.")
 
-            devel_archive, devel_version = search_private_archive(pkg_name, "sutton", group, index, config, branch="devel")
+            devel_archive, devel_version = search_private_archive(
+                pkg_name, "sutton", group, index, config, branch="devel"
+            )
             pkgInfo[pkg_name].devel_archive = devel_archive
             if devel_version:
                 info(f"{pkg_name} {devel_version} exists in {devel_archive}.")
@@ -1129,11 +1374,13 @@ def collect_pkg_info(data, check_private: bool = False, index=None, config=None)
             else:
                 debug(f"{pkg_name} doesn't exist in {devel_archive} yet.")
 
-        if pkg_name in pkgNamesInArchive and ''.join(v):
+        if pkg_name in pkgNamesInArchive and "".join(v):
             new_desc = _grouping_market_names(v)
             if "Lenovo" not in new_desc:
                 new_desc = "Lenovo " + new_desc
-            pkgInfo[pkg_name].old_desc = f"Sutton {group.title()} {codename.title()} platform"
+            pkgInfo[
+                pkg_name
+            ].old_desc = f"Sutton {group.title()} {codename.title()} platform"
             pkgInfo[pkg_name].new_desc = new_desc
 
     debug(json.dumps(pkgInfo, indent=4, sort_keys=True, cls=DataJSONEncoder))
@@ -1145,22 +1392,24 @@ def load_pkg_info(data) -> dict:
     pkgInfo = dict()
     data = json.load(data)
     for meta in data.keys():
-        pkgInfo[meta] = PkgInfo(ppa_archive=data[meta]['ppa_archive'],
-                                ppa_version=data[meta]['ppa_version'],
-                                git_version=data[meta]['git_version'],
-                                bootstrap_version=data[meta]['bootstrap_version'],
-                                real_version=data[meta]['real_version'],
-                                old_desc=data[meta]['old_desc'],
-                                new_desc=data[meta]['new_desc'],
-                                fingerprint=data[meta]['fingerprint'],
-                                staging_archive=data[meta]['staging_archive'],
-                                staging_version=data[meta]['staging_version'],
-                                devel_archive=data[meta]['devel_archive'],
-                                devel_version=data[meta]['devel_version'],
-                                oem_archive=data[meta]['oem_archive'],
-                                oem_version=data[meta]['oem_version'],
-                                ubuntu_version=data[meta]['ubuntu_version'],
-                                proposed_version=data[meta]['proposed_version'])
+        pkgInfo[meta] = PkgInfo(
+            ppa_archive=data[meta]["ppa_archive"],
+            ppa_version=data[meta]["ppa_version"],
+            git_version=data[meta]["git_version"],
+            bootstrap_version=data[meta]["bootstrap_version"],
+            real_version=data[meta]["real_version"],
+            old_desc=data[meta]["old_desc"],
+            new_desc=data[meta]["new_desc"],
+            fingerprint=data[meta]["fingerprint"],
+            staging_archive=data[meta]["staging_archive"],
+            staging_version=data[meta]["staging_version"],
+            devel_archive=data[meta]["devel_archive"],
+            devel_version=data[meta]["devel_version"],
+            oem_archive=data[meta]["oem_archive"],
+            oem_version=data[meta]["oem_version"],
+            ubuntu_version=data[meta]["ubuntu_version"],
+            proposed_version=data[meta]["proposed_version"],
+        )
 
     debug(json.dumps(pkgInfo, indent=4, sort_keys=True, cls=DataJSONEncoder))
     return pkgInfo
@@ -1184,8 +1433,8 @@ def deal_with_meta_git(pkg_name: str, pkg_info: PkgInfo, bootstrap: bool) -> boo
     if not result:
         return
 
-    if '.' in result.group(1):
-        project, group = result.group(1).split('.')
+    if "." in result.group(1):
+        project, group = result.group(1).split(".")
     else:
         project = result.group(1)
         group = None
@@ -1203,15 +1452,34 @@ def deal_with_meta_git(pkg_name: str, pkg_info: PkgInfo, bootstrap: bool) -> boo
         else:
             branch = f"{platform}-focal-oem"
 
-    git_command = ("git", "clone", "--depth", "1", "-b", branch, f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta", pkg_name)
+    git_command = (
+        "git",
+        "clone",
+        "--depth",
+        "1",
+        "-b",
+        branch,
+        f"https://git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta",
+        pkg_name,
+    )
 
     with TemporaryDirectory() as tmpdir:
         messages = list()
         os.chdir(tmpdir)
         _run_command(git_command)
-        git_version, _, _ = _run_command(["dpkg-parsechangelog", "--show-field", "Version", "-l", f"{pkg_name}/debian/changelog"])
+        git_version, _, _ = _run_command(
+            [
+                "dpkg-parsechangelog",
+                "--show-field",
+                "Version",
+                "-l",
+                f"{pkg_name}/debian/changelog",
+            ]
+        )
         if git_version != pkg_info.ppa_version:
-            critical(f"{pkg_name}'s version is {pkg_info.ppa_version} in ppa:oem-archive/{pkg_info.ppa_archive} but the version in Git repository is {git_version}.")
+            critical(
+                f"{pkg_name}'s version is {pkg_info.ppa_version} in ppa:oem-archive/{pkg_info.ppa_archive} but the version in Git repository is {git_version}."
+            )
             exit(1)
         git_dir = os.path.join(tmpdir, pkg_name)
 
@@ -1240,29 +1508,41 @@ def deal_with_meta_git(pkg_name: str, pkg_info: PkgInfo, bootstrap: bool) -> boo
             return False
 
         # Prepare the changelog and commit the changes.
-        commit_message = 'Update the ' + ' and'.join(', '.join(messages).rsplit(',', 1)) + f' for {args.kernel}.'
-        _run_command(['dch', '--increment', commit_message])
+        commit_message = (
+            "Update the "
+            + " and".join(", ".join(messages).rsplit(",", 1))
+            + f" for {args.kernel}."
+        )
+        _run_command(["dch", "--increment", commit_message])
         _run_command(["git", "add", "debian/changelog"])
-        _run_command(['git', 'commit', '-a', '-m', f"{commit_message}\n\nUpdated by oem-scripts {oem_scripts.__version__:.2f}."])
-
-        out, _, _ = _run_command(['git', 'show', '--color=always'])
-        if out != b'':
+        _run_command(
+            [
+                "git",
+                "commit",
+                "-a",
+                "-m",
+                f"{commit_message}\n\nUpdated by oem-scripts {oem_scripts.__version__:.2f}.",
+            ]
+        )
+
+        out, _, _ = _run_command(["git", "show", "--color=always"])
+        if out != b"":
             debug(f"({pkg_name}:{branch}) $ git show")
             debug(out)
 
         # Run autopkgtest
         if args.autopkgtest:
-            with open(f'{pkg_name}.list', 'r') as f:
+            with open(f"{pkg_name}.list", "r") as f:
                 source_list = f.read().strip()
 
             archives = set()
             archives.add(pkg_info.ppa_archive)
 
-            if project == 'somerville':
+            if project == "somerville":
                 common_archive = oem_archive.getPPAByName(name=project)
                 fingerprint = common_archive.signing_key_fingerprint
                 archives.add(f"{project}")
-            elif project == 'stella' or project == 'sutton':
+            elif project == "stella" or project == "sutton":
                 common_archive = oem_archive.getPPAByName(name=f"{project}-ouagadougou")
                 fingerprint = common_archive.signing_key_fingerprint
                 archives.add(f"{project}-ouagadougou")
@@ -1286,8 +1566,9 @@ def deal_with_meta_git(pkg_name: str, pkg_info: PkgInfo, bootstrap: bool) -> boo
                     if f"oem-archive/{ppa}/ubuntu" in url:
                         source_list += "\ndeb " + url + " focal main"
 
-            with open(f'autopkgtest-{pkg_name}-auto', 'w') as f:
-                f.write(f'''#!/bin/bash
+            with open(f"autopkgtest-{pkg_name}-auto", "w") as f:
+                f.write(
+                    f"""#!/bin/bash
 
 set -euo pipefail
 IFS=$'\n\t'
@@ -1319,54 +1600,83 @@ true
 ENDLINE
 chmod 755 "\\$root/usr/sbin/update-grub"
 END
-''')
+"""
+                )
             if args.debug:
-                _run_command(['cat', f'autopkgtest-{pkg_name}-auto'])
-            os.chmod(f'autopkgtest-{pkg_name}-auto', 0o755)
+                _run_command(["cat", f"autopkgtest-{pkg_name}-auto"])
+            os.chmod(f"autopkgtest-{pkg_name}-auto", 0o755)
             info(f"({pkg_name}:{branch}) $ run-autopkgtest lxc focal -C")
-            _run_command(['run-autopkgtest', 'lxc', 'focal', '-C'])
-            _run_command(['git', 'reset', '--hard', 'HEAD'])
-            _run_command(['git', 'clean', '-x', '-d', '-f'])
+            _run_command(["run-autopkgtest", "lxc", "focal", "-C"])
+            _run_command(["git", "reset", "--hard", "HEAD"])
+            _run_command(["git", "clean", "-x", "-d", "-f"])
 
         # Don't use UNRELEASED in the real meta.
         if not bootstrap:
-            _run_command(['sed', '-i', 's/UNRELEASED/focal/', 'debian/changelog'])
-            _run_command(['git', 'commit', '-a', '--amend', '--no-edit'])
+            _run_command(["sed", "-i", "s/UNRELEASED/focal/", "debian/changelog"])
+            _run_command(["git", "commit", "-a", "--amend", "--no-edit"])
 
         # Tag and find it out.
-        out, _, _ = _run_command(['gbp', 'tag'])
-        if out != b'':
+        out, _, _ = _run_command(["gbp", "tag"])
+        if out != b"":
             info(out)
-        out, _, _ = _run_command(['git', 'describe'])
-        if out != b'':
+        out, _, _ = _run_command(["git", "describe"])
+        if out != b"":
             tag = out.strip()
         info(tag)
 
         # Build Debian binary packages
-        _run_command(['gbp', 'buildpackage', '-us', '-uc'])
-        _run_command(['git', 'reset', '--hard', 'HEAD'])
-        _run_command(['git', 'clean', '-x', '-d', '-f'])
+        _run_command(["gbp", "buildpackage", "-us", "-uc"])
+        _run_command(["git", "reset", "--hard", "HEAD"])
+        _run_command(["git", "clean", "-x", "-d", "-f"])
 
         # Build Debian source packages
-        _run_command(['gbp', 'buildpackage', '-S', '-us', '-uc'])
-        _run_command(['git', 'reset', '--hard', 'HEAD'])
-        _run_command(['git', 'clean', '-x', '-d', '-f'])
+        _run_command(["gbp", "buildpackage", "-S", "-us", "-uc"])
+        _run_command(["git", "reset", "--hard", "HEAD"])
+        _run_command(["git", "clean", "-x", "-d", "-f"])
 
         # Show the commit
-        out, _, _ = _run_command(['git', 'show', '--color=always'])
-        if out != b'':
+        out, _, _ = _run_command(["git", "show", "--color=always"])
+        if out != b"":
             warning(f"({pkg_name}:{branch}) $ git show")
             print(out)
-            version, _, _ = _run_command(["dpkg-parsechangelog", "--show-field", "Version", "-l", f"debian/changelog"])
-            if not args.dry_run and yes_or_ask(args.yes, f"Would you like to commit and push the changes of {version} into {pkg_name}'s git {branch} branch?"):
+            version, _, _ = _run_command(
+                [
+                    "dpkg-parsechangelog",
+                    "--show-field",
+                    "Version",
+                    "-l",
+                    f"debian/changelog",
+                ]
+            )
+            if not args.dry_run and yes_or_ask(
+                args.yes,
+                f"Would you like to commit and push the changes of {version} into {pkg_name}'s git {branch} branch?",
+            ):
                 os.chdir(git_dir)
-                _run_command(['git', 'remote', 'add', 'oem-solutions-engineers', f"git+ssh://{lp.me.name}@git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta"])
-                _run_command(['git', 'push', 'oem-solutions-engineers'])
-                _run_command(['git', 'push', 'oem-solutions-engineers', tag])
-                if not args.dry_run and yes_or_ask(args.yes, f"Would you like to dput Debian source package into ppa:oem-archive/{pkg_info.ppa_archive}?"):
-                    os.chdir(os.path.join(git_dir, '..'))
-                    _run_command(['debsign', f'{pkg_name}_{version}_source.changes'])
-                    _run_command(['dput', f'ppa:oem-archive/{pkg_info.ppa_archive}', f'{pkg_name}_{version}_source.changes'])
+                _run_command(
+                    [
+                        "git",
+                        "remote",
+                        "add",
+                        "oem-solutions-engineers",
+                        f"git+ssh://{lp.me.name}@git.launchpad.net/~oem-solutions-engineers/pc-enablement/+git/oem-{project}-projects-meta",
+                    ]
+                )
+                _run_command(["git", "push", "oem-solutions-engineers"])
+                _run_command(["git", "push", "oem-solutions-engineers", tag])
+                if not args.dry_run and yes_or_ask(
+                    args.yes,
+                    f"Would you like to dput Debian source package into ppa:oem-archive/{pkg_info.ppa_archive}?",
+                ):
+                    os.chdir(os.path.join(git_dir, ".."))
+                    _run_command(["debsign", f"{pkg_name}_{version}_source.changes"])
+                    _run_command(
+                        [
+                            "dput",
+                            f"ppa:oem-archive/{pkg_info.ppa_archive}",
+                            f"{pkg_name}_{version}_source.changes",
+                        ]
+                    )
 
 
 def check_meta_git(pkg_name: str, pkg_info: PkgInfo, skip_bootstrap: False) -> None:
@@ -1383,84 +1693,119 @@ def check_meta_git(pkg_name: str, pkg_info: PkgInfo, skip_bootstrap: False) -> N
 
 cache = apt_pkg.Cache(progress=None)
 
-if args.subcommand == 'list':
+if args.subcommand == "list":
     for name in get_oem_meta_packages(cache):
         print(name)
-elif args.subcommand == 'subscribe':
+elif args.subcommand == "subscribe":
     for name in get_oem_meta_packages(cache):
         info(f"Checking the subscriptions for {name}...")
-        source = lp.distributions['ubuntu'].getSourcePackage(name=name)
-        if 'oem-solutions-engineers' in map(lambda x: x.subscriber.name, source.getSubscriptions()):
+        source = lp.distributions["ubuntu"].getSourcePackage(name=name)
+        if "oem-solutions-engineers" in map(
+            lambda x: x.subscriber.name, source.getSubscriptions()
+        ):
             info(f"ubuntu/{name} has subscribed oem-solutions-engineers.")
             continue
         warning(f"ubuntu/{name} didn't subscribe oem-solutions-engineers yet.")
-        if yes_or_ask(args.yes, f"Would you like to subscribe 'oem-solutions-engineers' for ubuntu/{name}?"):
+        if yes_or_ask(
+            args.yes,
+            f"Would you like to subscribe 'oem-solutions-engineers' for ubuntu/{name}?",
+        ):
             try:
                 # When a person is subscribed to a source package, one actually subscribe all bugs for it.
-                source.addBugSubscription(subscriber=lp.people['oem-solutions-engineers'])
+                source.addBugSubscription(
+                    subscriber=lp.people["oem-solutions-engineers"]
+                )
             except lazr.restfulclient.errors.Unauthorized as e:
-                error(f"{lp.me.name} does not have permission to subscribe oem-solutions-engineers.")
+                error(
+                    f"{lp.me.name} does not have permission to subscribe oem-solutions-engineers."
+                )
                 if args.verbose:
                     print(e)
                 exit(1)
-elif args.subcommand == 'unsubscribe':
-    source = lp.distributions['ubuntu'].getSourcePackage(name=args.pkgName)
+elif args.subcommand == "unsubscribe":
+    source = lp.distributions["ubuntu"].getSourcePackage(name=args.pkgName)
     subscriptions = source.getSubscriptions()
     for subscription in subscriptions:
-        if subscription.subscriber.name == 'oem-solutions-engineers':
+        if subscription.subscriber.name == "oem-solutions-engineers":
             info(f"ubuntu/{args.pkgName} has subscribed oem-solutions-engineers.")
-            if yes_or_ask(args.yes, f"Would you like to unsubscribe 'oem-solutions-engineers' for ubuntu/{args.pkgName}?"):
+            if yes_or_ask(
+                args.yes,
+                f"Would you like to unsubscribe 'oem-solutions-engineers' for ubuntu/{args.pkgName}?",
+            ):
                 try:
-                    source.removeBugSubscription(subscriber=lp.people['oem-solutions-engineers'])
+                    source.removeBugSubscription(
+                        subscriber=lp.people["oem-solutions-engineers"]
+                    )
                 except lazr.restfulclient.errors.Unauthorized as e:
-                    error(f"{lp.me.name} does not have permission to unsubscribe oem-solutions-engineers.")
+                    error(
+                        f"{lp.me.name} does not have permission to unsubscribe oem-solutions-engineers."
+                    )
                     if args.verbose:
                         print(e)
                     exit(1)
             exit(0)
-elif args.subcommand == 'update':
-    oem_scripts_config_ini = os.path.join(os.environ["HOME"],
-                                          ".config/oem-scripts/config.ini")
+elif args.subcommand == "update":
+    oem_scripts_config_ini = os.path.join(
+        os.environ["HOME"], ".config/oem-scripts/config.ini"
+    )
     oem_scripts_config = ConfigParser()
     oem_scripts_config.read(oem_scripts_config_ini)
-    config = oem_scripts_config['private']
+    config = oem_scripts_config["private"]
     if args.json:
         pkgInfo = load_pkg_info(args.json)
     elif args.meta:
-        r = requests.get(config['archive'] + "/dists/", auth=(config['username'], config['password']))
-        pkgInfo = collect_pkg_info(args.meta, check_private=True, index=r.text, config=config)
+        r = requests.get(
+            config["archive"] + "/dists/", auth=(config["username"], config["password"])
+        )
+        pkgInfo = collect_pkg_info(
+            args.meta, check_private=True, index=r.text, config=config
+        )
     else:
         print("You needto use --json or --meta.")
         exit(1)
     process_update_task(pkgInfo)
-elif args.subcommand == 'collect':
-    oem_scripts_config_ini = os.path.join(os.environ["HOME"],
-                                          ".config/oem-scripts/config.ini")
+elif args.subcommand == "collect":
+    oem_scripts_config_ini = os.path.join(
+        os.environ["HOME"], ".config/oem-scripts/config.ini"
+    )
     oem_scripts_config = ConfigParser()
     oem_scripts_config.read(oem_scripts_config_ini)
-    config = oem_scripts_config['private']
-    r = requests.get(config['archive'] + "/dists/", auth=(config['username'], config['password']))
+    config = oem_scripts_config["private"]
+    r = requests.get(
+        config["archive"] + "/dists/", auth=(config["username"], config["password"])
+    )
     if args.json:
-        pkgInfo = collect_pkg_info(args.json, check_private=True, index=r.text, config=config)
+        pkgInfo = collect_pkg_info(
+            args.json, check_private=True, index=r.text, config=config
+        )
     elif args.meta:
-        pkgInfo = collect_pkg_info(args.meta, check_private=True, index=r.text, config=config)
+        pkgInfo = collect_pkg_info(
+            args.meta, check_private=True, index=r.text, config=config
+        )
     else:
         print("You need to use --json or --meta.")
         exit(1)
-    args.output.write(json.dumps(pkgInfo, indent=4, sort_keys=True, cls=DataJSONEncoder))
+    args.output.write(
+        json.dumps(pkgInfo, indent=4, sort_keys=True, cls=DataJSONEncoder)
+    )
     args.output.write("\n")
-elif args.subcommand == 'staging-copy':
-    oem_scripts_config_ini = os.path.join(os.environ["HOME"],
-                                          ".config/oem-scripts/config.ini")
+elif args.subcommand == "staging-copy":
+    oem_scripts_config_ini = os.path.join(
+        os.environ["HOME"], ".config/oem-scripts/config.ini"
+    )
     oem_scripts_config = ConfigParser()
     oem_scripts_config.read(oem_scripts_config_ini)
-    config = oem_scripts_config['private']
+    config = oem_scripts_config["private"]
 
     if args.json:
         pkgInfo = load_pkg_info(args.json)
     elif args.meta:
-        r = requests.get(config['archive'] + "/dists/", auth=(config['username'], config['password']))
-        pkgInfo = collect_pkg_info(args.meta, check_private=True, index=r.text, config=config)
+        r = requests.get(
+            config["archive"] + "/dists/", auth=(config["username"], config["password"])
+        )
+        pkgInfo = collect_pkg_info(
+            args.meta, check_private=True, index=r.text, config=config
+        )
     else:
         print("You need to use --json or --meta.")
         exit(1)
@@ -1470,12 +1815,21 @@ elif args.subcommand == 'staging-copy':
     staging_locked = set()
     for pkg_name in sorted(pkgInfo.keys()):
         pkg_info = pkgInfo[pkg_name]
-        debug(f"{pkg_name} ppa: {pkg_info.ppa_version}, devel: {pkg_info.devel_version}, staging: {pkg_info.staging_version}.")
+        debug(
+            f"{pkg_name} ppa: {pkg_info.ppa_version}, devel: {pkg_info.devel_version}, staging: {pkg_info.staging_version}."
+        )
         if pkg_info.ppa_version != pkg_info.devel_version:
-            warning(f"{pkg_name} versions are not synced between ppa:oem-archive/{pkg_info.ppa_archive} and {pkg_info.devel_archive}.")
+            warning(
+                f"{pkg_name} versions are not synced between ppa:oem-archive/{pkg_info.ppa_archive} and {pkg_info.devel_archive}."
+            )
         elif pkg_info.staging_version == pkg_info.devel_version:
-            info(f"{pkg_name} {pkg_info.devel_version} (devel) == {pkg_info.staging_version} (staging) so it doesn't need to copy.")
-        elif apt_pkg.version_compare(pkg_info.staging_version, pkg_info.devel_version) > 0:
+            info(
+                f"{pkg_name} {pkg_info.devel_version} (devel) == {pkg_info.staging_version} (staging) so it doesn't need to copy."
+            )
+        elif (
+            apt_pkg.version_compare(pkg_info.staging_version, pkg_info.devel_version)
+            > 0
+        ):
             critical(f"This should never happen.")
             exit(1)
         else:
@@ -1485,65 +1839,90 @@ elif args.subcommand == 'staging-copy':
                 jobs[identity] = list()
             jobs[identity].append(pkg_name)
     debug(json.dumps(jobs, indent=4, sort_keys=True))
-    cloudberry = lp.projects['cloudberry']
-    assignee = lp.people['oem-archive']
+    cloudberry = lp.projects["cloudberry"]
+    assignee = lp.people["oem-archive"]
     tasks = cloudberry.searchTasks(
-        status=['New', 'Triaged', 'Confirmed', 'In Progress', 'Fix Committed'],
-        search_text='request of')
+        status=["New", "Triaged", "Confirmed", "In Progress", "Fix Committed"],
+        search_text="request of",
+    )
     for task in tasks:
         bug = task.bug
         for staging in sorted(dest):
-            if staging in bug.description and 'staging-lock' in bug.tags and 'cqa-verified-staging' not in bug.tags:
+            if (
+                staging in bug.description
+                and "staging-lock" in bug.tags
+                and "cqa-verified-staging" not in bug.tags
+            ):
                 debug(bug.description)
                 tags = ",".join(bug.tags)
-                for line in bug.description.split('\n'):
-                    if line.startswith('Package: '):
+                for line in bug.description.split("\n"):
+                    if line.startswith("Package: "):
                         package = line
-                warning(f"https://bugs.launchpad.net/bugs/{bug.id}\n\t({staging})\n\t[{tags}]\n\t{bug.title}\n\t{package}")
+                warning(
+                    f"https://bugs.launchpad.net/bugs/{bug.id}\n\t({staging})\n\t[{tags}]\n\t{bug.title}\n\t{package}"
+                )
                 staging_locked.add(staging)
     for job in jobs:
-        source, dest = job.split(':')
+        source, dest = job.split(":")
         if dest and dest in staging_locked and not args.ignore_staging_lock:
-            warning(f"The following OEM metapackages will be skipped due to the staging-lock of {dest}.\n" + '\n'.join(jobs[job]))
+            warning(
+                f"The following OEM metapackages will be skipped due to the staging-lock of {dest}.\n"
+                + "\n".join(jobs[job])
+            )
         else:
             title = f"request of copy_package [{source}]"
-            tags = ["archive-request", "via-request-script", f"oem-scripts-{oem_scripts.__version__:.2f}", "oem-metapackages"]
+            tags = [
+                "archive-request",
+                "via-request-script",
+                f"oem-scripts-{oem_scripts.__version__:.2f}",
+                "oem-metapackages",
+            ]
             if args.dry_run:
                 info(f"TITLE: {title}")
-                info("TAGS: " + ','.join(tags))
+                info("TAGS: " + ",".join(tags))
             else:
                 debug(f"TITLE: {title}")
-                debug("TAGS: " + ','.join(tags))
+                debug("TAGS: " + ",".join(tags))
             packages = list()
             for pkg_name in jobs[job]:
                 pkg_info = pkgInfo[pkg_name]
                 packages.append(f"{pkg_name} (=={pkg_info.devel_version})")
-            packages = ', '.join(packages)
+            packages = ", ".join(packages)
             distribution = "focal"
-            if dest.startswith('somerville'):
-                component = remove_suffix(dest, f"-{distribution}-staging").replace('-fossa', '')
+            if dest.startswith("somerville"):
+                component = remove_suffix(dest, f"-{distribution}-staging").replace(
+                    "-fossa", ""
+                )
             else:
                 debug(dest)
-                project, group, _ = dest.split('-', 2)
+                project, group, _ = dest.split("-", 2)
                 component = f"{project}.{group}"
-            production = distribution + '-' + component
+            production = distribution + "-" + component
             description = staging_copy_template.substitute(
                 source=source,
                 destination=dest,
                 packages=packages,
                 production=production,
-                username=config['username'],
-                url=config['url'],
+                username=config["username"],
+                url=config["url"],
                 distribution=distribution,
-                component=component)
+                component=component,
+            )
             print(description)
-            if not args.dry_run and yes_or_ask(args.yes, f"Would you like to create a cloudberry bug to copy the {packages} from {source} to {dest}?"):
-                bug = lp.bugs.createBug(description=description, target=cloudberry, title=title, tags=tags)
+            if not args.dry_run and yes_or_ask(
+                args.yes,
+                f"Would you like to create a cloudberry bug to copy the {packages} from {source} to {dest}?",
+            ):
+                bug = lp.bugs.createBug(
+                    description=description, target=cloudberry, title=title, tags=tags
+                )
                 for task in bug.bug_tasks:
-                    task.importance = 'High'
+                    task.importance = "High"
                     task.assignee = assignee
                     task.lp_save()
                 bug.lp_save()
-                print(f"The cloudberry staging copy bug has been created on {bug.web_link}.\n")
+                print(
+                    f"The cloudberry staging copy bug has been created on {bug.web_link}.\n"
+                )
 else:
     parser.print_help()
diff --git a/oem_scripts/LaunchpadLogin.py b/oem_scripts/LaunchpadLogin.py
index 0583ad2..01bae8b 100644
--- a/oem_scripts/LaunchpadLogin.py
+++ b/oem_scripts/LaunchpadLogin.py
@@ -8,20 +8,28 @@ import logging
 import os
 
 
-class ShutUpAndTakeMyTokenAuthorizationEngine(credentials.RequestTokenAuthorizationEngine):
+class ShutUpAndTakeMyTokenAuthorizationEngine(
+    credentials.RequestTokenAuthorizationEngine
+):
     """This stub class prevents launchpadlib from nulling out consumer_name
     in its demented campaign to force the use of desktop integration. """
 
-    def __init__(self, service_root, application_name=None, consumer_name=None,
-                 credential_save_failed=None, allow_access_levels=None):
+    def __init__(
+        self,
+        service_root,
+        application_name=None,
+        consumer_name=None,
+        credential_save_failed=None,
+        allow_access_levels=None,
+    ):
         super(ShutUpAndTakeMyTokenAuthorizationEngine, self).__init__(
-            service_root, application_name, consumer_name,
-            credential_save_failed)
+            service_root, application_name, consumer_name, credential_save_failed
+        )
 
 
-def launchpad_login(pkg, service_root='production', version='devel'):
+def launchpad_login(pkg, service_root="production", version="devel"):
     """Log into Launchpad API with stored credentials."""
-    creds_dir = os.path.expanduser(os.path.join('~', '.' + pkg))
+    creds_dir = os.path.expanduser(os.path.join("~", "." + pkg))
     if not os.path.exists(creds_dir):
         os.makedirs(creds_dir, 0o700)
     os.chmod(creds_dir, 0o700)
@@ -29,69 +37,83 @@ def launchpad_login(pkg, service_root='production', version='devel'):
     consumer_name = pkg
     return Launchpad.login_with(
         consumer_name=consumer_name,
-        credentials_file=os.path.join(creds_dir, 'launchpad.credentials'),
+        credentials_file=os.path.join(creds_dir, "launchpad.credentials"),
         service_root=api_endpoint,
         version=version,
         authorization_engine=ShutUpAndTakeMyTokenAuthorizationEngine(
-            service_root=api_endpoint,
-            consumer_name=consumer_name,
+            service_root=api_endpoint, consumer_name=consumer_name
         ),
     )
 
 
-class LaunchpadLogin():
+class LaunchpadLogin:
     """Try to unify all Launchpad login"""
-    def __init__(self, application_name='oem-scripts',
-                 service_root=None, launchpadlib_dir=None,
-                 version="devel", bot=False):
+
+    def __init__(
+        self,
+        application_name="oem-scripts",
+        service_root=None,
+        launchpadlib_dir=None,
+        version="devel",
+        bot=False,
+    ):
 
         if launchpadlib_dir is None:
             launchpadlib_dir = os.path.join(os.environ["HOME"], ".launchpadlib/cache")
 
         if service_root is None:
-            if os.environ.get('LAUNCHPAD_API') == lookup_service_root('staging'):
-                service_root = 'staging'
+            if os.environ.get("LAUNCHPAD_API") == lookup_service_root("staging"):
+                service_root = "staging"
             else:
-                service_root = 'production'
+                service_root = "production"
 
-        oem_scripts_config_ini = os.path.join(os.environ["HOME"],
-                                              ".config/oem-scripts/config.ini")
+        oem_scripts_config_ini = os.path.join(
+            os.environ["HOME"], ".config/oem-scripts/config.ini"
+        )
         launchpad_token = os.environ.get("LAUNCHPAD_TOKEN")
 
         if bot:
             logging.info("Using oem-taipei-bot credentials")
-            self.lp = launchpad_login('/', service_root)
+            self.lp = launchpad_login("/", service_root)
 
         elif launchpad_token:
             if launchpad_token == "::":
                 logging.info("Using anonymously login")
                 self.lp = Launchpad.login_anonymously(application_name, service_root)
             elif ":" in launchpad_token:
-                oauth_token, oauth_token_secret, oauth_consumer_key = launchpad_token.split(":", maxsplit=2)
-                self.lp = Launchpad.login(oauth_consumer_key,
-                                          oauth_token,
-                                          oauth_token_secret,
-                                          service_root=service_root,
-                                          cache=launchpadlib_dir,
-                                          version=version)
+                oauth_token, oauth_token_secret, oauth_consumer_key = launchpad_token.split(
+                    ":", maxsplit=2
+                )
+                self.lp = Launchpad.login(
+                    oauth_consumer_key,
+                    oauth_token,
+                    oauth_token_secret,
+                    service_root=service_root,
+                    cache=launchpadlib_dir,
+                    version=version,
+                )
             else:
                 logging.error(f"invalid LAUNCHPAD_TOKEN '{launchpad_token}'")
                 exit(1)
 
-        elif os.environ.get('LAUNCHPAD_API') and os.path.exists(oem_scripts_config_ini):
+        elif os.environ.get("LAUNCHPAD_API") and os.path.exists(oem_scripts_config_ini):
             logging.info("Using oem-scripts oauth token")
             oem_scripts_config = ConfigParser()
             oem_scripts_config.read(oem_scripts_config_ini)
-            config = oem_scripts_config['oem-scripts']
-            self.lp = Launchpad.login(config['oauth_consumer_key'],
-                                      config['oauth_token'],
-                                      config['oauth_token_secret'],
-                                      service_root=service_root,
-                                      cache=launchpadlib_dir,
-                                      version=version)
+            config = oem_scripts_config["oem-scripts"]
+            self.lp = Launchpad.login(
+                config["oauth_consumer_key"],
+                config["oauth_token"],
+                config["oauth_token_secret"],
+                service_root=service_root,
+                cache=launchpadlib_dir,
+                version=version,
+            )
         else:
             logging.info("Using oem-scripts login")
-            self.lp = Launchpad.login_with(application_name=application_name,
-                                           service_root=service_root,
-                                           launchpadlib_dir=launchpadlib_dir,
-                                           version=version)
+            self.lp = Launchpad.login_with(
+                application_name=application_name,
+                service_root=service_root,
+                launchpadlib_dir=launchpadlib_dir,
+                version=version,
+            )
diff --git a/oem_scripts/logging.py b/oem_scripts/logging.py
index 5351f86..0571d3c 100644
--- a/oem_scripts/logging.py
+++ b/oem_scripts/logging.py
@@ -22,29 +22,36 @@ import sys
 
 
 def setup_logging(debug=False, quiet=False):
-    logging.addLevelName(logging.DEBUG,
-                         "\033[1;96m%s\033[1;0m" %
-                         logging.getLevelName(logging.DEBUG))
-    logging.addLevelName(logging.INFO,
-                         "\033[1;32m%s\033[1;0m" %
-                         logging.getLevelName(logging.INFO))
-    logging.addLevelName(logging.WARNING,
-                         "\033[1;33m%s\033[1;0m" %
-                         logging.getLevelName(logging.WARNING))
-    logging.addLevelName(logging.ERROR,
-                         "\033[1;31m%s\033[1;0m" %
-                         logging.getLevelName(logging.ERROR))
-    logging.addLevelName(logging.CRITICAL,
-                         "\033[1;41m%s\033[1;0m" %
-                         logging.getLevelName(logging.CRITICAL))
+    logging.addLevelName(
+        logging.DEBUG, "\033[1;96m%s\033[1;0m" % logging.getLevelName(logging.DEBUG)
+    )
+    logging.addLevelName(
+        logging.INFO, "\033[1;32m%s\033[1;0m" % logging.getLevelName(logging.INFO)
+    )
+    logging.addLevelName(
+        logging.WARNING, "\033[1;33m%s\033[1;0m" % logging.getLevelName(logging.WARNING)
+    )
+    logging.addLevelName(
+        logging.ERROR, "\033[1;31m%s\033[1;0m" % logging.getLevelName(logging.ERROR)
+    )
+    logging.addLevelName(
+        logging.CRITICAL,
+        "\033[1;41m%s\033[1;0m" % logging.getLevelName(logging.CRITICAL),
+    )
     if debug:
-        logging.basicConfig(format='<%(levelname)s> %(message)s',
-                            level=logging.DEBUG,
-                            handlers=[logging.StreamHandler(sys.stdout)])
+        logging.basicConfig(
+            format="<%(levelname)s> %(message)s",
+            level=logging.DEBUG,
+            handlers=[logging.StreamHandler(sys.stdout)],
+        )
     elif not quiet:
-        logging.basicConfig(format='<%(levelname)s> %(message)s',
-                            level=logging.INFO,
-                            handlers=[logging.StreamHandler(sys.stdout)])
+        logging.basicConfig(
+            format="<%(levelname)s> %(message)s",
+            level=logging.INFO,
+            handlers=[logging.StreamHandler(sys.stdout)],
+        )
     else:
-        logging.basicConfig(format='<%(levelname)s> %(message)s',
-                            handlers=[logging.StreamHandler(sys.stdout)])
+        logging.basicConfig(
+            format="<%(levelname)s> %(message)s",
+            handlers=[logging.StreamHandler(sys.stdout)],
+        )
diff --git a/pkg-list b/pkg-list
index e5700ac..c5eeca0 100755
--- a/pkg-list
+++ b/pkg-list
@@ -29,8 +29,9 @@ from logging import debug, error, critical, info, warning
 from urllib.parse import urljoin
 
 
-parser = argparse.ArgumentParser(formatter_class=argparse.RawDescriptionHelpFormatter,
-                                 epilog="""
+parser = argparse.ArgumentParser(
+    formatter_class=argparse.RawDescriptionHelpFormatter,
+    epilog="""
 examples:
     pkg-list ubuntu-desktop --recommends > ubuntu-desktop.list
     pkg-list dkms --exclude ubuntu-desktop.list > dkms.list
@@ -39,63 +40,74 @@ examples:
     pkg-list linux-generic --exclude all.list
     pkg-list linux-generic-hwe-20.04 --exclude all.list
     pkg-list linux-oem-20.04 --exclude all.list
-    pkg-list linux-oem-20.04-edge --exclude all.list""")
-
-parser.add_argument("-d", "--debug",
-                    action="store_true",
-                    help="print debug messages")
-parser.add_argument("-l", "--long",
-                    action="store_true",
-                    help="print long list including the URL, MD5, SHA1 and SHA256.")
-parser.add_argument("--apt-dir",
-                    type=str,
-                    help="specify the dir for apt")
-parser.add_argument("--recommends",
-                    action="store_true",
-                    help="include recommends packages")
-parser.add_argument("--suggests",
-                    action="store_true",
-                    help="include suggests packages")
-parser.add_argument("--non-installed",
-                    action="store_true",
-                    help="only get non-installed packages per check current running environments")
-parser.add_argument("--fail-unavailable",
-                    action="store_true",
-                    help="Return error when any package is unavailable.")
-parser.add_argument("--exclude",
-                    metavar='pkg.list',
-                    type=argparse.FileType('r', encoding='UTF-8'),
-                    help="package names and versions to exclude.")
-parser.add_argument('pkgs',
-                    metavar='PKG_NAME',
-                    type=str, nargs='+',
-                    help='the names of Debian binary packages')
+    pkg-list linux-oem-20.04-edge --exclude all.list""",
+)
+
+parser.add_argument("-d", "--debug", action="store_true", help="print debug messages")
+parser.add_argument(
+    "-l",
+    "--long",
+    action="store_true",
+    help="print long list including the URL, MD5, SHA1 and SHA256.",
+)
+parser.add_argument("--apt-dir", type=str, help="specify the dir for apt")
+parser.add_argument(
+    "--recommends", action="store_true", help="include recommends packages"
+)
+parser.add_argument("--suggests", action="store_true", help="include suggests packages")
+parser.add_argument(
+    "--non-installed",
+    action="store_true",
+    help="only get non-installed packages per check current running environments",
+)
+parser.add_argument(
+    "--fail-unavailable",
+    action="store_true",
+    help="Return error when any package is unavailable.",
+)
+parser.add_argument(
+    "--exclude",
+    metavar="pkg.list",
+    type=argparse.FileType("r", encoding="UTF-8"),
+    help="package names and versions to exclude.",
+)
+parser.add_argument(
+    "pkgs",
+    metavar="PKG_NAME",
+    type=str,
+    nargs="+",
+    help="the names of Debian binary packages",
+)
 
 args = parser.parse_args()
 
-logging.addLevelName(logging.DEBUG,
-                     "\033[1;96m%s\033[1;0m" %
-                     logging.getLevelName(logging.DEBUG))
-logging.addLevelName(logging.INFO,
-                     "\033[1;32m%s\033[1;0m" %
-                     logging.getLevelName(logging.INFO))
-logging.addLevelName(logging.WARNING,
-                     "\033[1;33m%s\033[1;0m" %
-                     logging.getLevelName(logging.WARNING))
-logging.addLevelName(logging.ERROR,
-                     "\033[1;31m%s\033[1;0m" %
-                     logging.getLevelName(logging.ERROR))
-logging.addLevelName(logging.CRITICAL,
-                     "\033[1;41m%s\033[1;0m" %
-                     logging.getLevelName(logging.CRITICAL))
+logging.addLevelName(
+    logging.DEBUG, "\033[1;96m%s\033[1;0m" % logging.getLevelName(logging.DEBUG)
+)
+logging.addLevelName(
+    logging.INFO, "\033[1;32m%s\033[1;0m" % logging.getLevelName(logging.INFO)
+)
+logging.addLevelName(
+    logging.WARNING, "\033[1;33m%s\033[1;0m" % logging.getLevelName(logging.WARNING)
+)
+logging.addLevelName(
+    logging.ERROR, "\033[1;31m%s\033[1;0m" % logging.getLevelName(logging.ERROR)
+)
+logging.addLevelName(
+    logging.CRITICAL, "\033[1;41m%s\033[1;0m" % logging.getLevelName(logging.CRITICAL)
+)
 
 if args.debug:
-    logging.basicConfig(format='<%(levelname)s> %(message)s',
-                        level=logging.DEBUG,
-                        handlers=[logging.StreamHandler(sys.stdout)])
+    logging.basicConfig(
+        format="<%(levelname)s> %(message)s",
+        level=logging.DEBUG,
+        handlers=[logging.StreamHandler(sys.stdout)],
+    )
 else:
-    logging.basicConfig(format='<%(levelname)s> %(message)s',
-                        handlers=[logging.StreamHandler(sys.stdout)])
+    logging.basicConfig(
+        format="<%(levelname)s> %(message)s",
+        handlers=[logging.StreamHandler(sys.stdout)],
+    )
 
 
 def _debug_pkg(pkg: str) -> None:
@@ -106,12 +118,18 @@ def _debug_pkg(pkg: str) -> None:
     debug(dir(pkg))
 
     for attr in dir(pkg):
-        if not attr.startswith('__'):
+        if not attr.startswith("__"):
             if not isinstance(pkg.__getattribute__(attr), types.BuiltinFunctionType):
                 debug(f"{attr}: {pkg.__getattribute__(attr)}")
 
 
-def get_depends(pkg_name: str, depends_list: list, recommends: bool, suggests: bool, non_installed: bool) -> bool:
+def get_depends(
+    pkg_name: str,
+    depends_list: list,
+    recommends: bool,
+    suggests: bool,
+    non_installed: bool,
+) -> bool:
     """Recursively get all dependencies.
 
     Args:
@@ -158,25 +176,34 @@ def get_depends(pkg_name: str, depends_list: list, recommends: bool, suggests: b
         if pkg_name in map(lambda x: x[0], depends_list):
             continue
 
-        if any(pkg_name == name and version.ver_str == ver for name, ver in exclude_list):
+        if any(
+            pkg_name == name and version.ver_str == ver for name, ver in exclude_list
+        ):
             break
 
         if non_installed and pkg.current_ver == version:
             break
 
         for pfile in version.file_list:
-            if pfile[0].filename != '/var/lib/dpkg/status' and record.lookup(pfile):
-                url = urljoin("http://" + pfile[0].site, 'ubuntu/' + record.filename)
+            if pfile[0].filename != "/var/lib/dpkg/status" and record.lookup(pfile):
+                url = urljoin("http://" + pfile[0].site, "ubuntu/" + record.filename)
                 break
 
         debug(f"{pkg_name} {version.ver_str} {pkg.architecture} {url}")
-        item = (pkg_name, version.ver_str, url, record.hashes.find("MD5Sum"), record.hashes.find("SHA1"), record.hashes.find("SHA256"))
+        item = (
+            pkg_name,
+            version.ver_str,
+            url,
+            record.hashes.find("MD5Sum"),
+            record.hashes.find("SHA1"),
+            record.hashes.find("SHA256"),
+        )
         depends_list.append(item)
 
-        for target in ('PreDepends', 'Depends', 'Recommends', 'Suggests'):
-            if target == 'Recommends' and not recommends:
+        for target in ("PreDepends", "Depends", "Recommends", "Suggests"):
+            if target == "Recommends" and not recommends:
                 continue
-            if target == 'Suggests' and not suggests:
+            if target == "Suggests" and not suggests:
                 continue
             if target not in version.depends_list_str:
                 continue
@@ -188,10 +215,16 @@ def get_depends(pkg_name: str, depends_list: list, recommends: bool, suggests: b
                     if name in map(lambda x: x[0], depends_list):
                         found = True
                         break
-                    if arch == 'i386' and pkg.architecture == 'amd64':
+                    if arch == "i386" and pkg.architecture == "amd64":
                         name = name + ":i386"
                         pkg = cache[name]
-                    found = get_depends(name, depends_list, recommends=recommends, suggests=suggests, non_installed=non_installed)
+                    found = get_depends(
+                        name,
+                        depends_list,
+                        recommends=recommends,
+                        suggests=suggests,
+                        non_installed=non_installed,
+                    )
                     if found:
                         break
                 if not found and args.fail_unavailable:
@@ -205,11 +238,13 @@ if args.apt_dir:
     if args.debug:
         old = apt_pkg.config.dump()
     apt_pkg.config.set("Dir", args.apt_dir)
-    apt_pkg.config.set("Dir::State::status", os.path.join(args.apt_dir, "var/lib/dpkg/status"))
+    apt_pkg.config.set(
+        "Dir::State::status", os.path.join(args.apt_dir, "var/lib/dpkg/status")
+    )
     if args.debug:
         new = apt_pkg.config.dump()
         d = difflib.Differ()
-        diff = d.compare(old.split('\n'), new.split('\n'))
+        diff = d.compare(old.split("\n"), new.split("\n"))
         for line in diff:
             debug(line.strip())
     apt_pkg.init_system()
@@ -225,12 +260,18 @@ exclude_list = []
 
 if args.exclude:
     for line in args.exclude.readlines():
-        (name, ver) = line.strip().split(' ')
+        (name, ver) = line.strip().split(" ")
         if not any(name == _name and ver == _ver for _name, _ver in exclude_list):
             exclude_list.append((name, ver))
 
 for pkg in args.pkgs:
-    get_depends(pkg, pkg_list, recommends=args.recommends, suggests=args.suggests, non_installed=args.non_installed)
+    get_depends(
+        pkg,
+        pkg_list,
+        recommends=args.recommends,
+        suggests=args.suggests,
+        non_installed=args.non_installed,
+    )
 
 for pkg, ver, url, md5, sha1, sha256 in sorted(pkg_list):
     if args.long:
diff --git a/pkg-oem-meta b/pkg-oem-meta
index e5e3cf5..c924bfa 100755
--- a/pkg-oem-meta
+++ b/pkg-oem-meta
@@ -16,155 +16,164 @@ program_name = os.path.basename(sys.argv[0])
 
 setup_logging()
 
-if program_name == 'pkg-somerville-meta':
-    codename = 'somerville'
+if program_name == "pkg-somerville-meta":
+    codename = "somerville"
     Codename = codename.title()
-    brand = 'dell'
+    brand = "dell"
     parser = argparse.ArgumentParser(
         formatter_class=argparse.RawTextHelpFormatter,
         description=f"{Codename} platform meta package generator.",
         epilog=f"Ex. {program_name} --public-bug 1868254 -s focal -k"
-        " oem -p three-eyed-raven 0962")
-elif program_name == 'pkg-stella-meta':
-    codename = 'stella'
+        " oem -p three-eyed-raven 0962",
+    )
+elif program_name == "pkg-stella-meta":
+    codename = "stella"
     Codename = codename.title()
-    brand = 'hp'
+    brand = "hp"
     parser = argparse.ArgumentParser(
         formatter_class=argparse.RawTextHelpFormatter,
         description=f"{Codename} platform meta package generator.",
-        epilog=f"Ex. {program_name} -s focal -k oem"
-        " -g cmit -p beedrill 8594")
-elif program_name == 'pkg-sutton-meta':
-    codename = 'sutton'
+        epilog=f"Ex. {program_name} -s focal -k oem" " -g cmit -p beedrill 8594",
+    )
+elif program_name == "pkg-sutton-meta":
+    codename = "sutton"
     Codename = codename.title()
-    brand = 'lenovo'
+    brand = "lenovo"
     parser = argparse.ArgumentParser(
         formatter_class=argparse.RawTextHelpFormatter,
         description=f"{Codename} platform meta package generator.",
-        epilog=f"Ex. {program_name} -s focal -k oem"
-        " -g bachman -p banaing S08")
+        epilog=f"Ex. {program_name} -s focal -k oem" " -g bachman -p banaing S08",
+    )
 else:
-    error('This program can not be executed.')
+    error("This program can not be executed.")
     exit(1)
 
-parser.add_argument('-k', '--kernel',
-                    choices=['linux-oem-20.04', 'linux-oem-20.04b', 'linux-oem-20.04c', 'linux-generic-hwe-20.04'],
-                    default='linux-oem-20.04',
-                    help="Specify the kernel meta. [linux-oem-20.04|linux-oem-20.04b|linux-oem-20.04c|linux-generic-hwe-20.04]")
+parser.add_argument(
+    "-k",
+    "--kernel",
+    choices=[
+        "linux-oem-20.04",
+        "linux-oem-20.04b",
+        "linux-oem-20.04c",
+        "linux-generic-hwe-20.04",
+    ],
+    default="linux-oem-20.04",
+    help="Specify the kernel meta. [linux-oem-20.04|linux-oem-20.04b|linux-oem-20.04c|linux-generic-hwe-20.04]",
+)
 info = UbuntuDistroInfo()
 try:
     # for bionic
-    series = lsb_release.get_lsb_information()['CODENAME']
+    series = lsb_release.get_lsb_information()["CODENAME"]
 except AttributeError:
     # for focal
-    series = lsb_release.get_os_release()['CODENAME']
-
-parser.add_argument('-s', '--series', choices=info.supported(), default=series,
-                    help=f"Ubuntu series, such as {series} by default.")
-parser.add_argument('--public-bug',
-                    help="Launchpad public bug number.",
-                    type=int)
-parser.add_argument('--private-bug',
-                    help="Launchpad private bug number.",
-                    type=int)
-
-if codename == 'somerville':
-    parser.add_argument('bios_id', nargs='+', help="BIOS ID")
-    parser.add_argument('-p', '--platform', help="platform tag", required=True)
-elif codename == 'stella':
-    parser.add_argument('-g', '--group', help="OEM-group", required=True)
-    parser.add_argument('-p', '--platform', help="platform-codename",
-                        required=True)
-    parser.add_argument('sd_id', nargs='+',
-                        help="subsystem device ID, such as 0962")
-elif codename == 'sutton':
-    parser.add_argument('-g', '--group', help="OEM-group", required=True)
-    parser.add_argument('-p', '--platform', help="platform-codename",
-                        required=True)
-    parser.add_argument('bios_ver', nargs='+',
-                        help="First three chars in bios version, "
-                        + "such as S08 or bvnLENOVO:bvrS08")
+    series = lsb_release.get_os_release()["CODENAME"]
+
+parser.add_argument(
+    "-s",
+    "--series",
+    choices=info.supported(),
+    default=series,
+    help=f"Ubuntu series, such as {series} by default.",
+)
+parser.add_argument("--public-bug", help="Launchpad public bug number.", type=int)
+parser.add_argument("--private-bug", help="Launchpad private bug number.", type=int)
+
+if codename == "somerville":
+    parser.add_argument("bios_id", nargs="+", help="BIOS ID")
+    parser.add_argument("-p", "--platform", help="platform tag", required=True)
+elif codename == "stella":
+    parser.add_argument("-g", "--group", help="OEM-group", required=True)
+    parser.add_argument("-p", "--platform", help="platform-codename", required=True)
+    parser.add_argument("sd_id", nargs="+", help="subsystem device ID, such as 0962")
+elif codename == "sutton":
+    parser.add_argument("-g", "--group", help="OEM-group", required=True)
+    parser.add_argument("-p", "--platform", help="platform-codename", required=True)
+    parser.add_argument(
+        "bios_ver",
+        nargs="+",
+        help="First three chars in bios version, " + "such as S08 or bvnLENOVO:bvrS08",
+    )
 args = parser.parse_args()
 
 platform = args.platform.lower()
 Platform = platform.title()
 series = args.series
-versions = dict(zip(info.get_all(result='codename'),
-                    info.get_all(result='release')))
-version = versions[series].split(' ')[0]
+versions = dict(zip(info.get_all(result="codename"), info.get_all(result="release")))
+version = versions[series].split(" ")[0]
 
 # Sanity check
-if codename == 'somerville':
-    group = ''
+if codename == "somerville":
+    group = ""
     if args.platform.startswith("fossa-"):
-        error('Please remove fossa- prefix from the platform name.')
+        error("Please remove fossa- prefix from the platform name.")
         exit(1)
     for bios_id in args.bios_id:
-        if not re.match('[0-9a-fA-F]{4}$', bios_id):
-            error('Invalid BIOS ID: {%s}' % bios_id)
+        if not re.match("[0-9a-fA-F]{4}$", bios_id):
+            error("Invalid BIOS ID: {%s}" % bios_id)
             exit(1)
-    meta = 'oem-' + codename + '-' + platform + '-meta'
-elif codename == 'stella':
+    meta = "oem-" + codename + "-" + platform + "-meta"
+elif codename == "stella":
     group = args.group.lower()
     for sd_id in args.sd_id:
-        if not re.match('[0-9a-fA-F]{4}$', sd_id):
-            error('Invalid subsystem device ID: {%s}' % sd_id)
+        if not re.match("[0-9a-fA-F]{4}$", sd_id):
+            error("Invalid subsystem device ID: {%s}" % sd_id)
             exit(1)
-    meta = 'oem-' + codename + '.' + group + '-' + platform + '-meta'