@@ -70,11 +70,13 @@ def update_assets(token, organization):
7070 Returns:
7171 None
7272 """
73+ logger .info ("Updating assets." )
7374 assets : List [Asset ] = list_assets (token )
7475 asset_to_team_map = get_teams_for_assets (organization )
7576 for asset in assets :
7677 teams_to_update = asset_to_team_map .get (asset .asset_name , [])
7778 if teams_to_update :
79+ logger .info (f"Adding teams { teams_to_update } to asset { asset .asset_name } " )
7880 add_teams_to_asset (token , asset , teams_to_update )
7981
8082
@@ -118,12 +120,14 @@ def process_teams(token, organization):
118120 Returns:
119121 List[str]: The names of the teams to delete.
120122 """
123+ logger .info ("Processing teams." )
121124 desired_teams = [t .name for t in organization .teams ]
122125 existing_teams : List [TeamObject ] = get_existing_teams (token )
123126 existing_team_names = [team .name for team in existing_teams ]
124127 teams_to_create = get_teams_to_create (desired_teams , existing_team_names )
125128 teams_to_delete = get_teams_to_delete (desired_teams , existing_team_names )
126129 if teams_to_create :
130+ logger .info (f"Creating { len (teams_to_create )} teams: { teams_to_create } " )
127131 create_teams (token , teams_to_create )
128132 return teams_to_delete
129133
@@ -151,6 +155,7 @@ def get_teams_for_assets(organization: Organization) -> Dict[str, List[str]]:
151155
152156
153157def main ():
158+ logger .info ("Starting the update process." )
154159 jit_token = get_jit_jwt_token ()
155160 if not jit_token :
156161 logger .error ("Failed to retrieve JWT token. Exiting..." )
@@ -163,9 +168,6 @@ def main():
163168
164169 teams_to_delete = process_teams (jit_token , organization )
165170
166- if teams_to_delete :
167- print (teams_to_delete )
168-
169171 update_assets (jit_token , organization )
170172
171173 delete_teams (jit_token , teams_to_delete )
0 commit comments